这是有一台机器宕机后的节点状态,1 宕机了 生成者向kafka 集群发送 120条消息, 1 分区已经宕机,还能接受 20条消息吗? 消费端消费,只消费到100条消息, 1 分区上的消息没有消费 上面的情况算是丢消息了吧,大佬请问怎么处理呢。
你的消息没有丢,应该是消费者的offset位置丢了。
新版的kafka,消费者位置存储在主题为
__consumer_offsets
中,如果它的副本数为1
,那就会产生这种现象。扩容参考:kafka命令大全
好的,我先看看,我的副本刚开始是3个,宕机一台,还有两台; 这种情况 patition1 是不是就不应该再接受到消息了呢? 这里也不太明白 ~
会不会接受,取决与
min.insync.replicas
参考:Kafka Broker配置
你的答案