kafka中消费一条数据

在Apache Kafka中，消费者从主题（Topic）中消费数据通常涉及以下几个步骤：

1. **创建消费者实例**：首先，需要创建一个Kafka消费者实例，通过`KafkaConsumer`类或其高级版本`HighLevelConsumer`。你需要提供配置信息，如bootstrap servers（服务器地址）、组ID（Group ID，用于分区均衡）以及可能的偏移量策略。

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "my-consumer-group");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);

2. **订阅主题**：通过`consumer.subscribe()`方法订阅感兴趣的topic列表。

Set<String> topics = new HashSet<>();
topics.add("my-topic");
consumer.subscribe(topics);

3. **开始消费**：调用`consumer.poll()`方法定期从Kafka集群拉取消息。这个方法会阻塞，直到有新的消息到达或者超时。

List<ConsumerRecord<String, String>> records = consumer.poll(100); // 拉取时间为100毫秒
for (ConsumerRecord<String, String> record : records) {
    // 处理接收到的消息
    System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
}

4. **提交偏移量**：消费完成后，为了持久化消费进度并避免数据重复处理，需要定期或手动调用`consumer.commitSync()`提交当前消费的偏移量。

5. **关闭连接**：当不再需要消费时，记得调用`consumer.close()`关闭消费者。