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,
