这家伙太懒,什么都没留下
已更新
已经解决了,十分感谢
带入到环境变量中:
export KAFKA_OPTS="-Djava.security.auth.login.config=/etc/kafka/kafka_client_jaas.conf"
然后执行:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --consumer.config config/consumer.properties
你客户端是什么?还是用的命令行。
你好,应该怎么传递给kafka呢,我也是刚学习kafka,不是太了解
客户端