You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Sachin Nikumbh <sa...@yahoo.com.INVALID> on 2017/05/05 02:08:34 UTC
Trouble fetching messages with error "Skipping fetch for partition"
Hello,
I am using kafka 0.10.1.0 and failing to fetch messages with following error message in the log :
****************************************Skipping fetch for partition MYPARTITION because there is an in-flight request to MYMACHINE:9092 (id: 0 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher)
****************************************
Has anyone seen this error? How do I fix this?
Any help would be greatly appreciated,
ThanksSachin
Re: 答复: Trouble fetching messages with error "Skipping fetch for partition"
Posted by Sachin Nikumbh <sa...@yahoo.com.INVALID>.
Hello,
Thanks for your response. I am attaching the log file. The topic has 3 partitions and the client application has a thread pool of size 3 representing the consumer group. Each thread has its own instance of KafkaConsumer. I am only using a single kafka broker. The same code with the same setup works fine on windows. It seems to have issues on Debian 8.
ThanksSachin
From: Hu Xi <hu...@hotmail.com>
To: "users@kafka.apache.org" <us...@kafka.apache.org>; Sachin Nikumbh <sa...@yahoo.com>
Sent: Thursday, May 4, 2017 10:31 PM
Subject: 答复: Trouble fetching messages with error "Skipping fetch for partition"
This is a trace-level log which means that consumer already creates a fetch request to the given node from which you are reading data so no more requests cannot be created. Did you get any other warn-level or error-level logs when failing to fetching message?
________________________________
发件人: Sachin Nikumbh <sa...@yahoo.com.INVALID>
发送时间: 2017年5月5日 10:08
收件人: users@kafka.apache.org
主题: Trouble fetching messages with error "Skipping fetch for partition"
Hello,
I am using kafka 0.10.1.0 and failing to fetch messages with following error message in the log :
****************************************Skipping fetch for partition MYPARTITION because there is an in-flight request to MYMACHINE:9092 (id: 0 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher)
****************************************
Has anyone seen this error? How do I fix this?
Any help would be greatly appreciated,
ThanksSachin
答复: Trouble fetching messages with error "Skipping fetch for partition"
Posted by Hu Xi <hu...@hotmail.com>.
This is a trace-level log which means that consumer already creates a fetch request to the given node from which you are reading data so no more requests cannot be created. Did you get any other warn-level or error-level logs when failing to fetching message?
________________________________
发件人: Sachin Nikumbh <sa...@yahoo.com.INVALID>
发送时间: 2017年5月5日 10:08
收件人: users@kafka.apache.org
主题: Trouble fetching messages with error "Skipping fetch for partition"
Hello,
I am using kafka 0.10.1.0 and failing to fetch messages with following error message in the log :
****************************************Skipping fetch for partition MYPARTITION because there is an in-flight request to MYMACHINE:9092 (id: 0 rack: null) (org.apache.kafka.clients.consumer.internals.Fetcher)
****************************************
Has anyone seen this error? How do I fix this?
Any help would be greatly appreciated,
ThanksSachin