Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-17321

Kafka 1.1.1 consumer cannot get any topic-partition

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Critical
    • Resolution: Unresolved
    • 1.1.1
    • None
    • consumer
    • Kafka 1.1.1 with Scala 2.11
    • Important

    Description

      We are using Kafka 1.1.1, in one day that our consumers (using subscribe mode) restarted themselves, but during the rebalance, consumers could assign topic-partitions until generation 229, after generation 229, the logs shown that the consumer could not get any topic-partition, event if we tried to restart consumer in order to trigger rebalance again, but it had no effect, logs shown that there were still no partition(Setting newly assigned partitions []).

      But both Kafka coordinator and consumer did not show any exception logs and error, it just rebalance the group as normal.

      The solution was we restarted the Group Coordinator, which trigger the broker high availability switch, let the leader of the __consumer_offsets switch to another broker and switch back, once the coordinator switched, that problem was solve immediately.

      Is there anyone meet similar problem before?  Can anybody explain this thing?

      Very Thanks.

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            uncleyi YI ZHAOPU
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: