我有两个不同的应用程序实例从一个主题中消费消息,两个应用程序具有相同的group.id和consumer.id值。
这些消息只会被一个应用程序读取还是两个应用程序都会读取?如果在两个不同的应用程序中具有相同的consumer.id,它是否被视为一组中的两个消费者,还是仅被视为该组中的单个消费者?
例如:App1实例,group.id = conGrp1,consumer.id = consumer
App2实例,group.id = conGrp1,consumer.id = consumer1
即使运行了两个不同的应用程序实例,我们是否仍然只有一个具有一个消费者的组?
这些消息只会被一个应用程序读取还是两个应用程序都会读取?如果在两个不同的应用程序中具有相同的consumer.id,它是否被视为一组中的两个消费者,还是仅被视为该组中的单个消费者?
例如:App1实例,group.id = conGrp1,consumer.id = consumer
App2实例,group.id = conGrp1,consumer.id = consumer1
即使运行了两个不同的应用程序实例,我们是否仍然只有一个具有一个消费者的组?
consumer.id
在文档中已经不再提及了,所以我不知道它到底有什么用。http://kafka.apache.org/documentation/#consumerconfigs。话虽如此,这里只考虑`group.id`的作用。 - OneCricketeerconsumer.id
,但我假设这个值是自动设置的,那么为什么你要手动设置它呢? - OneCricketeer