We are implementing apache kafka as a distributed messaging middleware that would be exhaustively used for asynchronous communications.
I have a few use cases where i want to be able to publish a message to the kafka broker and listen for a reply to that particular message (like we would using correlation id in rabbit mq).
I read about the apache kafka protocol and seems like they do use the correlation id internally. But i couldn't find any examples that are using that correlation id anywhere.
Can you please suggest if there is way to do that with apache kafka?