Hello all,

I am looking to add a "resend" option to my program where a user can specify an 
older message they would like to produce through Kafka again, for whatever 
reason. I can get the topic and offset for each message from my logs after 
consuming a message, but I do not see a way to get which partition the message 
was in. Currently, I do not have a key associated with the messages.

My thoughts right now lean towards adding a key system to know which partition 
each message will go to, but I was wondering if there are better alternatives 
to this.


Thank you,

Andrew Greer

Reply via email to