kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Domenico Di Giulio (JIRA)" <j...@apache.org>
Subject [jira] [Issue Comment Deleted] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress
Date Sun, 23 Apr 2017 15:09:04 GMT

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

Domenico Di Giulio updated KAFKA-5016:
--------------------------------------
    Comment: was deleted

(was: I am currently out of the office, with limited access to my e-mail.
I will be back at work on April 26.


** Le e-mail provenienti dalla Banca d'Italia sono trasmesse in buona fede e non comportano
alcun vincolo nè creano obblighi per la Banca stessa, salvo che ciò non sia espressamente
previsto da un accordo scritto. Questa e-mail è confidenziale. Qualora l'avesse ricevuta
per errore, La preghiamo di comunicarne via e-mail la ricezione al mittente e di distruggere
il contenuto. La informiamo inoltre che l'utilizzo non autorizzato del messaggio o dei suoi
allegati potrebbe costituire reato. Grazie per la collaborazione.
-- E-mail from Bank of Italy are sent in good faith but they are neither binding on the Bank
nor to be understood as creating any obligation on its part except where provided for in a
written agreement. This e-mail is confidential. If you have received it by mistake, please
inform the sender by reply e-mail and delete it from your system. Please also note that the
unauthorized disclosure or use of the message or any attachments could be an offence. Thank
you for your cooperation. **
)

> Consumer hang in poll method while rebalancing is in progress
> -------------------------------------------------------------
>
>                 Key: KAFKA-5016
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5016
>             Project: Kafka
>          Issue Type: Bug
>          Components: core
>    Affects Versions: 0.10.1.0, 0.10.2.0
>            Reporter: Domenico Di Giulio
>            Assignee: Vahid Hashemian
>         Attachments: Kafka 0.10.2.0 Issue (TRACE) - Server + Client.txt, Kafka 0.10.2.0
Issue (TRACE).txt, KAFKA_5016.java
>
>
> After moving to Kafka 0.10.2.0, it looks like I'm experiencing a hang in the rebalancing
code. 
> This is a test case, not (still) production code. It does the following with a single-partition
topic and two consumers in the same group:
> 1) a topic with one partition is forced to be created (auto-created)
> 2) a producer is used to write 10 messages
> 3) the first consumer reads all the messages and commits
> 4) the second consumer attempts a poll() and hangs indefinitely
> The same issue can't be found with 0.10.0.0.
> See the attached logs at TRACE level. Look for "SERVER HANGS" to see where the hang is
found: when this happens, the client keeps failing any hearbeat attempt, as the rebalancing
is in progress, and the poll method hangs indefinitely.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message