有一套单副本的kafka集群,宕机一台后使用消费命令无法正常消费数据。有什么办法可以恢复,使消费者正常使用吗?
__consumer_offsets 是有副本的,旧的消费组不影响,但新的消费者无法正常消费数据。
新的消费者指的是什么?
比如我直接用命令行启动一个消费,这个时候对应topic有持续数据写入,命令行窗口并没有返回任何数据。
可能是相同的消费者组名,你在消费者命令指定一下消费者组名。
--group.id
也是不行的,只能够指定消费 leader不是 1 的分区 --partition 0;但是旧的组是不影响的,可能他的信息已经在 __consumer_offsets 里面存储。同时我也有个疑问,宕机一台就会影响到整个topic(单副本的)对新的消费组的消费,那这个是不是有点不对,或者我的配置配的不太对。
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
__consumer_offsets 是有副本的,旧的消费组不影响,但新的消费者无法正常消费数据。
新的消费者指的是什么?
比如我直接用命令行启动一个消费,这个时候对应topic有持续数据写入,命令行窗口并没有返回任何数据。
可能是相同的消费者组名,你在消费者命令指定一下消费者组名。
--group.id
也是不行的,只能够指定消费 leader不是 1 的分区 --partition 0;但是旧的组是不影响的,可能他的信息已经在 __consumer_offsets 里面存储。
同时我也有个疑问,宕机一台就会影响到整个topic(单副本的)对新的消费组的消费,那这个是不是有点不对,或者我的配置配的不太对。
你的答案