我试图从火花流到安全的kafka代理(使用SASL明文机制)。我使用的是火花流- kafka -0-8版本,im使用kafka broker版本0.10.2。
我得到的问题是,当火花放电流卡夫卡没有返回任何输出。
我的问题是:
补充:
这里的细节也许可以解释这个问题。
为kafka broker在server.properties中启用sasl平面的附加参数
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
listeners=SASL_PLAINTEXT://:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
super.users=User:admin这也是我的kafka_jaas_server.conf
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin1!"
user_admin="admin1!"
user_aldys="admin1!";
};我还包括我的jaas配置时,启动卡夫卡经纪人。通过编辑最后一行的kafka-server-start.sh:
exec $base_dir/kafka-run-class.sh $EXTRA_ARGS -Djava.security.auth.login.config=/etc/kafka/kafka_jaas_server.conf kafka.Kafka "$@"发布于 2018-09-09 14:37:19
我不认为kafka0-8支持sasl,从文档中可以很清楚地看出,只有kafka0-10具有sasl功能,而kafka0-10不支持Python。
https://stackoverflow.com/questions/44961243
复制相似问题