例如,我的kafka消费者(在consumer Group 1中)正在阅读来自Kafka主题A的消息。
现在,如果该消费者在失败之前消费了12条消息。当消费者重新启动,并且现在它有不同的消费者组(即消费者组2)时,问题1 -?在重启时,它会从偏移量(或位置)中停止的地方继续,因为该偏移量是由Kafka和/或ZooKeeper存储
我是第一次接触Kafka,正在尝试验证我的设计。下面是我所拥有的。 我有一个生产者发布到一个主题,并有一堆容器(我的web应用程序部署在那里),其中一个消费者在每个容器上运行。每个使用者都应该阅读该主题中的所有消息。例如,假设有3条关于主题的消息- m0,m1,m2,那么consumer1 to consumerN应该独立地读取m0,m1,m2。每个消费者在处理读取消息后都会立即提交offset。每当重新部署我<em
我无法启动kafka,因为文件\00000000000000000000.timeindex正被另一个进程使用。Prepare to shutdown (kafka.server.KafkaServer) at kafka.log.Log.loadSegments(Log.scala:376)
at kafka.log.Log.<