Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- security.inter.broker.protocol=PLAINTEXT
- sasl.mechanism.inter.broker.protocol=PLAIN
- sasl.enabled.mechanisms=PLAIN
- advertised.listeners=SASL_PLAINTEXT://example.com:9095,PLAINTEXT://example.com:9092
- listeners = SASL_PLAINTEXT://0.0.0.0:9095,PLAINTEXT://0.0.0.0:9092
- from kafka import KafkaProducer
- producer = KafkaProducer(bootstrap_servers='example.com:9095', security_protocol="SASL_PLAINTEXT", sasl_mechanism='PLAIN', sasl_plain_username='username', sasl_plain_password='password')
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement