Kafka - with Java/Python
What is wrong with this code?
from confluent_kafka import Producer
p = Producer({'bootstrap.servers': 'localhost:9092'})
p.produce('topic', key=123, value='data')
p.flush()