我理解kafka将主题的数据安排在多个分区上,并且一个消费者组中的消费者被分配了不同的分区,他们可以在那里接收数据:
partition-1 partition-2 partition-3 partition-4 partition-5 partition-6
|____________| |____________| |____________|
| | |
consumer-1 consumer-2 consumer-3我的问题是:
consumers,它们是由主机/IP还是通过客户端连接来标识的?换句话说,如果我启动两个线程或进程,使用相同的使用者组运行相同的kafka客户端代码,它们是一个消费者还是两个消费者?
发布于 2021-10-22 13:43:19
首先,消费者并不是线程安全的。
单独线程/进程中的多个实例不会被视为组中的同一个客户端,但当您描述使用者组时,它们确实会显示主机信息。
https://stackoverflow.com/questions/69673496
复制相似问题