我必须在ConsumerGroup中设置动物园管理员IP地址,而不是卡夫卡-主机IP地址.因为我已经将复制因子设置为3和3,所以创建了代理。因此,如果一个主机失败了,那么另一个主机就可以接管。当我试图在ConsumerGroup中放置动物园管理员IP地址而不是Kafka-主机IP地址时,它没有收到任何来自Producer的消息。var kafka = require('kafka-node')
function creat
我正在使用kafka-node ConsumerGroup来阅读卡夫卡的信息。我想从主题中读取新消息,即不是所有以前未使用的消息,而是在创建ConsumerGroup之后到达的消息。我可以通过在每次创建groupId时创建一个新的ConsumerGroup来使用这个方法,但是我希望避免这种方法,因为这会在ConsumerGroup服务器上创建大量的groupIds和存储偏移量。set offset: ", data);
if (err) logger.error("error", e
我正在使用python (aioredis)和redis流。我还希望依赖于第二个、第三个等消费者组中的有序处理-所有这些都依赖于发送到一个流的相同消息。含义:ordered processing within group 1 ... n
whereas consumer 1 ... n per gro