Kafka是否向所有消费者发送新消息通知？

Kafka会将新消息广播到所有的消费者组，但是具体每个消费者是否接收到新消息通知还需要根据消费方式和消费状态来判断。

以下是使用Java客户端的实现示例：

首先，创建一个消费者对象：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "test-group"); // 指定消费者所属的组
props.put("enable.auto.commit", "true"); // 自动提交消费位移
props.put("auto.commit.interval.ms", "1000");
props.put("session.timeout.ms", "30000");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

消费者创建完毕后，我们需要订阅一个主题，代码如下：

consumer.subscribe(Arrays.asList("test-topic"));

现在，我们已经成功订阅了一个主题，下一步是等待新消息的到来：

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(1000);
    for (ConsumerRecord<String, String> record : records) {
        System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
    }
}

在该示例中，我们使用一个while循环和poll()方法来等待新消息的到来，如果有新消息，则将其打印出来。当消费者接收到新消息时，它会自动向Kafka提交消费位移，以便下次从正确的位置继续消费。

综上所述，Kafka会将新消息广播到所有的消费者组，但是每个消费者是否接收到新消息通知还需要根据消费方式和消费状态来判断。