Kafka可以用于多个独立消费者连续读取吗？

是的，Kafka可以用于多个独立消费者连续读取。您可以使用Kafka的消费者组特性来同时处理相同主题和分区的消息流。

以下是一个使用Java语言编写的示例代码，演示如何使用Kafka消费者组处理消息流：

Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("group.id", "test-group");

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props); consumer.subscribe(Arrays.asList("test-topic"));

while (true) { ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100)); for (ConsumerRecord<String, String> record : records) { System.out.printf("Topic: %s, Partition: %d, Offset: %d, Key: %s, Value: %s\n", record.topic(), record.partition(), record.offset(), record.key(), record.value()); } }

在上面的示例中，我们创建了一个Kafka消费者，并订阅了一个名为“test-topic”的主题。在无限循环中，我们使用“poll”方法读取消息记录，并对每个消息记录进行处理。使用Kafka的消费者组特性，多个独立消费者可以同时从同一个主题和分区中读取消息。