[ https://issues.apache.org/jira/browse/NIFI-2739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470550#comment-15470550 ]
ASF subversion and git services commented on NIFI-2739: ------------------------------------------------------- Commit 8d6e12fdc4002f6eba52edcf0670df40217eb43a in nifi's branch refs/heads/master from [~markap14] [ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=8d6e12f ] NIFI-2739: Call KafkaConsumer.wakeup() if consumer is blocking for at least 30 seconds when OnUnscheduled is called > ConsumeKafka and ConsumeKafka_0_10 can block indefinitely if unable to > communicate with Kafka broker > ---------------------------------------------------------------------------------------------------- > > Key: NIFI-2739 > URL: https://issues.apache.org/jira/browse/NIFI-2739 > Project: Apache NiFi > Issue Type: Bug > Components: Extensions > Reporter: Mark Payne > Assignee: Mark Payne > Fix For: 1.1.0 > > > If I use ConsumeKafka and point to a broker that is in a bad state, I see > ConsumeKafka block indefinitely. -- This message was sent by Atlassian JIRA (v6.3.4#6332)