java消费kafka

Java消费Kafka可以使用Kafka提供的Java客户端库，这个库提供了一个叫做KafkaConsumer的类，用于建立一个Kafka消费者。以下是一个简单的Java消费Kafka的示例代码：

import org.apache.kafka.clients.consumer.*;

import java.util.Collections;
import java.util.Properties;

public class KafkaConsumerExample {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.setProperty("bootstrap.servers", "localhost:9092");
        props.setProperty("group.id", "test-group");
        props.setProperty("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        props.setProperty("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

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

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

在这个示例中，我们创建了一个Kafka消费者，它订阅了一个名为"test-topic"的Kafka主题。然后我们使用poll()方法从Kafka主题中读取消息，并使用for循环遍历消息记录并打印它们的偏移量、键和值。