哥哥们,有遇到过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通过扩容,将原本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分区数扩容对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
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。
社区圈子