Hi Achintya, We have a JIRA for this problem: https://issues. apache.org/jira/browse/KAFKA-3834. Do you expect the client to raise an exception in this case or do you just want to keep it from blocking indefinitely? If the latter, you could escape the poll from another thread using wakeup().
Thanks, Jason On Wed, Aug 31, 2016 at 12:11 PM, Ghosh, Achintya (Contractor) < achintya_gh...@comcast.com> wrote: > Hi there, > > Kafka consumer gets stuck at consumer.poll() method if my current > datacenter is down and replicated messages are in remote datacenter. > > How to solve that issue? > > Thanks > Achintya >
