Your client library might be sending a message that is too old or too new for your broker to understand.
What version is your Kafka client library, and what version is your broker? -James Sent from my iPhone > On Sep 22, 2017, at 4:09 PM, Vignesh <vignesh.v...@gmail.com> wrote: > > Hi, > > In which scenarios would we get "INVALID_REQUEST" for a Version 1 "Offset > Request" (https://kafka.apache.org/protocol#The_Messages_Offsets) ? > > I searched for INVALID_REQUEST in https://github.com/apache/kafka and below > is the only file that seems related. > > https://github.com/apache/kafka/blob/96ba21e0dfb1a564d5349179d844f020abf1e08b/clients/src/main/java/org/apache/kafka/common/protocol/Errors.java > > Here, I see that invalid request is returned only on duplicate topic > partition. Is that the only reason? > > The description for the error is broader though. > > " > This most likely occurs because of a request being malformed by the client > library or the message was sent to an incompatible broker. See the broker > logs for more details. > > " > > Thanks, > Vignesh.
