kafka消费顺序在哪调整

Kafka消费顺序可以在消费者端进行调整。具体来说，可以通过设置消费者的max.poll.records属性来控制每次 poll() 操作返回的最大记录数，从而影响消费顺序。当max.poll.records设置为1时，每次 poll() 只返回一条记录，这样可以确保按照消息到达 Kafka 的顺序进行消费。

以下是一个示例代码，展示了如何在 Kafka 消费者中设置max.poll.records属性：

Properties props = new Properties();
props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
props.put(ConsumerConfig.GROUP_ID_CONFIG, "test");
props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, "1"); // 设置每次 poll() 返回的最大记录数为 1

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("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
    }
}

在这个示例中，我们将max.poll.records设置为1，这样消费者就会按照消息到达 Kafka 的顺序进行消费。请注意，这种方法可能会降低消费者的吞吐量，因为每次 poll() 操作都会等待直到有新的消息可用。如果需要处理大量消息，可以考虑增加max.poll.records的值，或者使用其他方法来确保消费顺序，例如使用单个分区或者使用事务。