I am just sending the request directly using my own client, Protocol api version I used is "1" https://kafka.apache.org/protocol#The_Messages_Offsets
Broker version is .10.2.0 . .This broker version supports protocol version 1. Where are the logs related to such errors stored? Also, is this error level enabled by default? If not, How can I enable it? Thanks, Vignesh. On Sun, Sep 24, 2017 at 12:52 PM, James Cheng <wushuja...@gmail.com> wrote: > 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/96ba21e0dfb1a564d5349179d844f0 > 20abf1e08b/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. >
