Great question! Let's break this down clearly for you:

新版Kafka Consumer对consumer.id的支持情况 #

Yes，基于org.apache.kafka.clients.consumer.KafkaConsumer的新版Kafka Consumer（从Kafka 0.10.x开始引入）完全支持设置consumer.id。不过这个参数在新版里的定位有所变化：它更多是作为消费者实例的自定义标识，用于日志排查、监控（比如JMX指标）等场景，不再像旧版客户端那样直接参与消费者组的核心协调逻辑。

如果不手动设置，Kafka依然会自动生成一个唯一的consumer.id，格式通常类似consumer-<线程ID>-<时间戳>，用来区分不同的消费者实例。

具体配置方法 #

你可以通过两种常见方式设置自定义的consumer.id：

1. 原生Kafka客户端直接配置 #

在创建KafkaConsumer实例前，将consumer.id添加到配置属性中：

import org.apache.kafka.clients.consumer.KafkaConsumer;
import java.util.Properties;

public class CustomConsumerExample {
    public static void main(String[] args) {
        Properties consumerProps = new Properties();
        consumerProps.put("bootstrap.servers", "kafka-broker-1:9092,kafka-broker-2:9092");
        consumerProps.put("group.id", "order-events-consumer-group");
        // 设置自定义consumer.id
        consumerProps.put("consumer.id", "order-events-consumer-instance-001");
        consumerProps.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        consumerProps.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

        KafkaConsumer<String, String> consumer = new KafkaConsumer<>(consumerProps);
        // 后续消费逻辑...
    }
}

2. 框架集成场景（以Spring Kafka为例） #

如果使用Spring Kafka这类封装框架，可以在配置文件中直接指定：

spring:
  kafka:
    consumer:
      group-id: order-events-consumer-group
      bootstrap-servers: kafka-broker-1:9092,kafka-broker-2:9092
      properties:
        # 配置自定义consumer.id
        consumer.id: spring-kafka-order-consumer-001

内容的提问来源于stack exchange，提问作者Giorgos Myrianthous