You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Vignesh <vi...@gmail.com> on 2017/09/22 23:09:37 UTC
In which scenarios would "INVALID_REQUEST" be returned for "Offset Request"
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.
Re: In which scenarios would "INVALID_REQUEST" be returned for
"Offset Request"
Posted by Vignesh <vi...@gmail.com>.
We see even when we use https://github.com/edenhill/librdkafka nuget
version .11.0, https://www.nuget.org/packages/librdkafka.redist/
-Vignesh.
On Tue, Sep 26, 2017 at 11:03 AM, Vignesh <vi...@gmail.com> wrote:
> 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 <wu...@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 <vi...@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/96ba21e0dfb1a564d534917
>> 9d844f020abf1e08b/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.
>>
>
>
Re: In which scenarios would "INVALID_REQUEST" be returned for
"Offset Request"
Posted by Vignesh <vi...@gmail.com>.
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 <wu...@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 <vi...@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.
>
Re: In which scenarios would "INVALID_REQUEST" be returned for "Offset Request"
Posted by James Cheng <wu...@gmail.com>.
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 <vi...@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.