Can you show us some snippet of code where you are consuming this data?
Which language consumer are you using and how many consumers are part of
the (same) group? Which exact version of Kafka broker and which version
of the client side libraries?
-Jaikiran
On 14/11/17 6:01 PM, chandarasekaran m wrote:
Hi Team,
Can any one explain how data is consumed from high-level
consumer? As per my understanding ,fetcher thread fetch the data from
broker then push in to blocking queue(in-memory queue per topic) and
application threads(consumer) will read data from blocking queue.
In my application consumer thread never seen message but partition for that
thread(consumer) has lag(has messages).
It means fetcher thread never pushed data in to blocking queue? can any one
explain ? please
With Regards
M.Chandarasekaran,
