cloudkarafka / python-kafka-example Goto Github PK

in produce, I am getting an error
% Message failed delivery: KafkaError{code=_MSG_TIMED_OUT,val=-192,str="Local: Message timed out"}
Can you please help?

line 36: p.poll(0)
it seems comment this line the code still works

Hello Experts,

Where should I place the certificate? I followed the installation guidelines but didn't find where to put the certificate. Please guide as I am getting error while running python consumer.py command.

Regards

Issue:

• consumer.py and producer.py append .test to the CLOUDKARAFKA_TOPIC_PREFIX. This throws an error in the producer when you press ctrl-d:
  % Message failed delivery: KafkaError{code=UNKNOWN_TOPIC_OR_PART,val=3,str="Broker: Unknown topic or partition"}
• No messages are received in the consumer.
• README.md says it's a username, but that isn't the default topic name: export CLOUDKARAFKA_TOPIC_PREFIX="same_as_username"
• Requirement to send an EOF to producer should be documented.

Expected results:
Messages typed in producer.py's buffer would show up in terminal running consumer.py.

Steps to reproduce:

1. Clone repo
2. Follow directions to export env vars
3. Attempt to produce / consume messages