kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sachin Nikumbh <saniku...@yahoo.com.INVALID>
Subject Re: 答复: Trouble fetching messages with error "Skipping fetch for partition"
Date Fri, 05 May 2017 03:17:14 GMT
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 <huxi_2b@hotmail.com>
 To: "users@kafka.apache.org" <users@kafka.apache.org>; Sachin Nikumbh <sanikumbh@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 <sanikumbh@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


   
Mime
  • Unnamed multipart/mixed (inline, None, 0 bytes)
View raw message