Hello. Generally, a Kafka Consumer consumes stored messages from Kafka Broker(s) when the Consumer has been executed.
I, however, want to create a function that only consumes incoming messages after executing, instead of consuming the previously stored messages as I mentioned above, for real-time application. Is it doable? If yes, how could it be implemented? Any example code or reference would really be helpful for me. Thanks in advance! Best regards KIM
