配置SASL_PLAINTEXT后Kafka消费者无消息输出，求排查方案

1. 消费者未配置SASL认证参数 #

生产者能成功发送消息，说明生产者端SASL配置已生效，但消费者端大概率遗漏了认证配置：

• 命令行启动消费者时，需明确指定SASL相关参数：

  bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic your_topic \
  --property security.protocol=SASL_PLAINTEXT \
  --property sasl.mechanism=PLAIN \
  --property sasl.jaas.config="org.apache.kafka.common.security.plain.PlainLoginModule required username='consumer_user' password='consumer_pass';"
  

• 若使用消费者配置文件（如consumer.properties），需添加以下配置项：

  security.protocol=SASL_PLAINTEXT
  sasl.mechanism=PLAIN
  sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="consumer_user" password="consumer_pass";
  

2. 未配置ACL读取权限 #

启用SASL后，Kafka不会自动赋予用户主题读写权限，需手动配置ACL：

• 先确认server.properties中已开启ACL组件：

  authorizer.class.name=org.apache.kafka.common.security.auth.SimpleAclAuthorizer
  super.users=User:admin;User:kafka  # 配置超级用户，避免Kafka自身权限异常
  

• 使用kafka-acls.sh给消费者用户添加对应主题的读取权限：

  bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 \
  --add --allow-principal User:consumer_user --operation Read --topic your_topic
  

3. 消费者offset重置策略问题 #

如果消费者使用的是新消费组（group.id未使用过），默认auto.offset.reset=latest，只会消费启动后产生的新消息。若测试消息是在消费者启动前发送的，自然无法读取：

• 启动消费者时添加参数--property auto.offset.reset=earliest，或在配置文件中设置auto.offset.reset=earliest，让消费者从最早的消息偏移量开始消费。

4. JAAS配置加载异常 #

• 检查Kafka启动脚本中的KAFKA_OPTS是否正确加载了kafka_jaas.conf，确保路径无误：

  export KAFKA_OPTS="-Djava.security.auth.login.config=/opt/kafka/config/kafka_jaas.conf"
  

• 若消费者是自定义服务，需确保JVM参数中加载了消费者专属的JAAS配置文件：

  -Djava.security.auth.login.config=/opt/kafka/config/consumer_jaas.conf
  

  consumer_jaas.conf内容示例：

  KafkaClient {
      org.apache.kafka.common.security.plain.PlainLoginModule required
      username="consumer_user"
      password="consumer_pass";
  };
  

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