如何像Java一样连接Kafka python来接受jaas的用户名和密码？
如何像Java一样连接Kafka python来接受jaas的用户名和密码？
提问于 2021-01-15 10:09:11
使用一个现有的工作Java示例，我正在尝试使用python-kafka和confluent_kafka库编写一个等同于生产者的python。如何使用下面的信息在Python语言中配置sasl.jass.config？
import java.util.Properties;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord;
...
Properties props = new Properties();
...
props.put("sasl.jaas.config", "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"<Kafka_Username>\" password=\"<Kafka_Password>\";");
Producer<String, String> producer = new KafkaProducer<>(props);回答 1
Stack Overflow用户
回答已采纳
发布于 2021-01-27 21:16:54
这对我很管用
from confluent_kafka import Producer
SECURITY_PROTOCOL = "SASL_SSL"
SASL_MECHANISM = "PLAIN"
conf = {
'bootstrap.servers': SERVERS,
'sasl.mechanisms': SASL_MECHANISM,
'security.protocol': SECURITY_PROTOCOL,
'sasl.username': SASL_USERNAME,
'sasl.password': SASL_PASSWORD,
...
}
consumer = Producer(conf)页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/65729535
复制相关文章
相似问题
腾讯云开发者
