Dear Experts,
I have a producer that pushes the Messages to kafka and a producer which is
a spark algorithm to pick up the messages using a zookeeper instance.
Below is the Spark log: Can anyone tell me what am I doing wrong?
Kafka Topic details:
*The command I used to create the Topic:*
Are you sure your producer and consumer are pointed to the same topic? I
see RECUR_TRANS in your logs but you mentioned creating RECURRING_TRANS.
If thats not the issue. I have a few questions to get more informations.
- Can you list & describe the relevant topics using the kafka-topics