云消息队列 Kafka 版 云计算背景

哥哥们,有遇到过Kafka分区扩容,Flink CDC会报错的情况嘛?

哥哥们,有遇到过Kafka分区扩容,Flink CDC会报错的情况嘛?Caused by: org.apache.kafka.common.errors.WakeupException at org.apache.kafka.clients.consumer.internals.ConsumerNe...

想问下rocketmq能像kafka那样,直接通过在配置文件添加磁盘目录后,达到扩容的效果么,谢谢!

想问下rocketmq能像kafka那样,直接通过在配置文件添加磁盘目录后,达到扩容的效果么,谢谢!

消息队列Kafka入门课程

4 课时 |
3098 人已学 |
免费

分布式消息系统 Kafka 快速入门

24 课时 |
640 人已学 |
免费
开发者课程背景图

大佬们,Kafka通过扩容,将原本0,1,2扩容到0,1,2,3,4,5,随后将topicA的所有副

大佬们,Kafka通过扩容,将原本0,1,2扩容到0,1,2,3,4,5,随后将topicA的所有副本reassign到3,4,5节点上了,下线了0,1,2节点,应用端再次启动后被阻塞了,有人遇到过这个问题么?Kafka版本0.11.0.2

记一次 Kafka 集群线上扩容

记一次 Kafka 集群线上扩容

前段时间收到某个 Kafka 集群的生产客户端反馈发送消息耗时很高,于是花了一段时间去排查这个问题,最后该集群进行扩容,由于某些主题的当前数据量实在太大,在对这些主题迁移过程中花费了很长一段时间,不过这个过程还算顺利,因为在迁移过程中也做足了各方面的调研,包括分区重平衡过程中对客户端的影响ÿ...

kafka分区数扩容对flink任务有什么影响吗?

如题,flink任务当前从我了解来看,是直接先查询所有分区信息,然后assign方式指定分区消费的。 包括,之前多个任务使用相同group.id消费相同topic并不会相互影响,也是这个原因,因为是通过assign方式消费,而不是分组订阅方式。 当然相关的还有一个分区发现机制(我是开启的)。 在这种...

kafka扩容

需求: 对全kafka集群中的topic  :imp-imps-app-web增加partition和replicate 1.kafka 扩容 首先按照搭建步骤,在其他机器上搭建集群,kafka的配置文件中 zkconnect 要保持与原kafka一致 2.验证kafka新节点是否加入集群...

更新时间 2023-06-06 17:30:35

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

社区圈子

消息队列
消息队列
消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。
20+人已加入
加入
相关电子书
更多
任庆盛|Flink CDC + Kafka 加速业务实时化
消息队列 Kafka 版差异化特性
2019大数据技术公开课第五季—kafka 数据如何同步到 MaxCompute
立即下载 立即下载 立即下载

云消息队列 Kafka 版您可能感兴趣