kafka消费者消费多个topic消息java实现

您好，关于kafka消费者消费多个topic消息的Java实现，可以使用KafkaConsumer类中的subscribe方法来订阅多个topic，示例代码如下：

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("topic1", "topic2"));

然后在消费消息时，可以使用poll方法来获取消息，示例代码如下：

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());
}
}

希望能对您有所帮助。