Is there a way to make a microservice both a producer and a consumer using kafka-python?
I’m new to this domain and was trying to implement an inter-service communication system using the kafka-python library. I’m having a problem with said implementation where the consumer in the Main block is stalled and nothing really seems to happen. Checking the kafka queue via a GUI tool tells me that the message has been sent from the viewing microservice to the main one in the topic ‘send_topic’, leading me to wonder if running both a producer and a consumer in the same service might be causing this. Any suggestions with respect to the code or alternate approaches would be appreciated, thanks!
Is there a way make a microservice both a producer and a consumer using kafka-python?
I’m new to this domain and was trying to implement an inter-service communication system using the kafka-python library. I’m having a problem with said implementation where the consumer in the Main block is stalled and nothing really seems to happen. Checking the kafka queue via a GUI tool tells me that the message has been sent from the viewing microservice to the main one in the topic ‘send_topic’, leading me to wonder if running both a producer and a consumer in the same service might be causing this. Any suggestions with respect to the code or alternate approaches would be appreciated, thanks!