Kafka多位制作人为同一主题写作？
假设我有一个主题T1，它有三个分区，即P1、P2和P3。其中p1是领导者，rest是追随者。
共有1个答案
Leader不依赖于生产者或消费者，因此p1将始终作为Leader返回。抵消对生产者来说并不重要，它们是按消费者群体定义的。偏移量确定使用者组读取和提交了哪些消息。
消费者总是会阅读所有的消息，不管是哪个生产者发布的。
-
所以我有一个设计，其中我有多个生产者P1、P2、P3、P4... PN写入单个主题T1，它有32个分区。 另一方面，我在一个消费者组中最多有32个消费者。 我想负载平衡我的消息消耗 阅读文档时，我可以看到3个选项： 1。自己定义分区（缺点是我必须知道最后一条消息发送到哪里，或者为每个生产者定义分区范围P） 2。定义一个密钥并将分区决定权交给Kafka哈希算法（缺点-负载平衡将在运气好的情况下定义）
-
我想使用spring cloud stream framework创建一个kafkaendpoint，它将有一个http post api到。如何动态更改属性 我可以使用实现来实现上述功能，但不知道是否有可能在Spring中开发此功能。
-
在构建Kafka Streams拓扑时，可以通过两种不同的方式对多个主题的读取进行建模： 读取具有相同源节点的所有主题。 选项1相对于选项2是否有相对优势，反之亦然？所有主题都包含相同类型的数据，并具有相同的数据处理逻辑。
-
我已经设置了kafka客户端，它可以产生和消费消息，当我们把有效载荷从生产者发送到主题时，它可以正常工作，所以我有问题生产者现在第一个消息我可以发送到主题，我也可以从kafka主题中消费，现在我尝试发送第二个消息，但是消费者没有从kafka主题中读取第二个消息，知道这里发生了什么吗？ Producer.js consumer.js
-
我有以下用例：将来自单个数据源的日志文件推送到Kafka主题（例如主题1）。有一个消费者将从中读取并转换为json格式并写回另一个主题（主题2）。另一个期望json中的数据将从主题2读取的消费者将进行一些其他修改并写回另一个主题（主题3）。 我的问题是，除了创建3个不同的主题之外，我能否创建一个主题，并让这些多个制作者写同一个主题？既然不能为生产者设置组id，我的消费者如何知道从哪个分区读取？我从
-
我正在尝试加载一个简单的文本文件，而不是Kafka中的标准输入。下载Kafka后，我执行了以下步骤： 开始动物园管理员： zookeeper-server-start.sh配置zookeeper.properties 已启动服务器 kafka-server-start.sh配置server.properties 创建了一个名为“test”的主题： ＜code＞bin/kafka主题。sh--创建-