export KAFKA_OPTS="-Djava.security.auth.login.config=/etc/kafka1/conf/jaas.conf -Djava.security.krb5.conf=/etc/kafka1/conf/krb5.conf -Dsun.security.krb5.debug=false"

新建 security-client.properties 中并添加

security.protocol=SASL_PLAINTEXT
sasl.mechanism=GSSAPI
sasl.kerberos.service.name=kafka

./kafka-console-consuemr.sh --bootstrap-server localhost:9092 --topic topic001 --consumer.config ../config/security-client.properties