Kafka是否会向所有消费者发送通知，告知新消息的到来？

Kafka会将新消息持久化到主题的分区中，消费者通过消费者组订阅主题并实时拉取分区消息。因此不需要发送通知，而是由消费者主动轮询获取新消息。

以下是Java代码示例：

//创建消费者 KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props); //订阅主题 consumer.subscribe(Collections.singletonList(TOPIC));

while (true) { //拉取消息 ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100)); for (ConsumerRecord<String, String> record : records) { //处理消息 System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value()); } }