java - 暂停具有多个消费者的kafka主题

Question

我有一个关于多个分区的主题，该主题的 4 个消费者都在同一个消费者组中。如果一个消费者暂停主题，其他三个消费者是否会暂停。如果有办法做到这一点？如果是，相反，如果一个取消暂停，所有其他消费者都会取消暂停。

Answer 1

KafkaConsumer 中的 pause() 和 resume() 操作不会在 Kafka 代理的协议(protocol)级别生成任何请求。调用 pause()，只是将分配的分区设置为暂停，在本地将它们标记为“不可获取”。 Kafka 协议(protocol)有一个 Fetch 请求，用于从客户端请求服务器获取记录(这是在 poll() 方法中发生的事情)。当分配的分区暂停时，它们被视为“不可获取”，因此不会发送获取请求。消费者和经纪人之间没有沟通；经纪人不知道您对消费者调用了 pause() 。所以答案是否定的:即使 pause() 处于分区级别而不是整个主题级别，其他消费者也不会被暂停。