You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Guozhang Wang (JIRA)" <ji...@apache.org> on 2015/11/12 19:00:14 UTC

[jira] [Assigned] (KAFKA-2819) ConsumerConsume throw unexpected exception during clean shutdown

     [ https://issues.apache.org/jira/browse/KAFKA-2819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Guozhang Wang reassigned KAFKA-2819:
------------------------------------

    Assignee: Guozhang Wang

> ConsumerConsume throw unexpected exception during clean shutdown
> ----------------------------------------------------------------
>
>                 Key: KAFKA-2819
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2819
>             Project: Kafka
>          Issue Type: Bug
>            Reporter: Jun Rao
>            Assignee: Guozhang Wang
>             Fix For: 0.9.0.0
>
>
> Saw the following error during a clean shutdown.
> [2015-11-12 13:12:58,918] INFO [ConsumerFetcherManager-1447333891220] All connections stopped (kafka.consumer.ConsumerFetcherManager)
> [2015-11-12 13:12:58,921] ERROR Error processing message, terminating consumer process:  (kafka.tools.ConsoleConsumer$)
> java.util.NoSuchElementException
> 	at kafka.utils.IteratorTemplate.next(IteratorTemplate.scala:39)
> 	at kafka.consumer.ConsumerIterator.next(ConsumerIterator.scala:46)
> 	at kafka.consumer.OldConsumer.receive(BaseConsumer.scala:79)
> 	at kafka.tools.ConsoleConsumer$.process(ConsoleConsumer.scala:101)
> 	at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:64)
> 	at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:42)
> 	at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)