kafka怎么读取指定位置消息

Kafka可以通过设置consumer的offset来读取指定位置的消息。在创建consumer实例时，可以通过指定partition和offset来设置consumer的起始位置。具体步骤如下：

1. 创建Kafka consumer实例时，通过设置auto.offset.reset属性为none，禁止consumer自动重置offset。这样可以确保consumer从指定的offset开始读取消息。

Properties props = new Properties(); props.put("bootstrap.servers", "localhost:9092"); props.put("group.id", "test-group"); props.put("enable.auto.commit", "false"); props.put("auto.offset.reset", "none");  KafkaConsumer consumer = new KafkaConsumer<>(props); 

2. 使用assign()方法将consumer分配到指定的partition，并设置起始offset。

TopicPartition partition = new TopicPartition("test-topic", 0); consumer.assign(Collections.singletonList(partition)); consumer.seek(partition, 10); // 从offset为10的位置开始读取消息 

3. 接着就可以使用poll()方法来获取消息了。

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

通过以上步骤，就可以在Kafka中读取指定位置的消息。