我是第一次接触Kafka,正在尝试验证我的设计。下面是我所拥有的。 我有一个生产者发布到一个主题,并有一堆容器(我的web应用程序部署在那里),其中一个消费者在每个容器上运行。这些消费者不在消费者组中,并且独立地消费消息。每个使用者都应该阅读该主题中的所有消息。例如,假设有3条关于主题的消息- m0,m1,m2,那么consumer1 to consumerN应该独立地读取m0,m1,m2。每个消费者</em
我正在尝试在Windows操作系统上进行简单的kafka配置。我的zookeeper和kafka安装使用默认配置(数据和日志目录路径除外)。at kafka.log.LogSegment.changeFileSuffixes(LogSegment.scala:415)
at kafka.log.Log.kafka_2.11-1.1.0\kafka-logs\discrete-topic-0\00000000000000