java.lang.RuntimeException: Failed to initialize the consumer

Google Groups | Unknown author | 2 years ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.
  1. 0

    kafka.common.ConsumerRebalanceFailedException ... Can't rebalance after retries

    Google Groups | 2 years ago | Unknown author
    java.lang.RuntimeException: Failed to initialize the consumer

    Root Cause Analysis

    1. kafka.common.ConsumerRebalanceFailedException

      secor_backup_secor-directattributionraw01_15669_14 can't rebalance after 5 retries

      at kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance()
    2. Apache Kafka
      ZookeeperConsumerConnector.createMessageStreamsByFilter
      1. kafka.consumer.ZookeeperConsumerConnector$ZKRebalancerListener.syncedRebalance(ZookeeperConsumerConnector.scala:633)
      2. kafka.consumer.ZookeeperConsumerConnector.kafka$consumer$ZookeeperConsumerConnector$$reinitializeConsumer(ZookeeperConsumerConnector.scala:905)
      3. kafka.consumer.ZookeeperConsumerConnector$WildcardStreamsHandler.<init>(ZookeeperConsumerConnector.scala:939)
      4. kafka.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:160)
      5. kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:101)
      6. kafka.javaapi.consumer.ZookeeperConsumerConnector.createMessageStreamsByFilter(ZookeeperConsumerConnector.scala:108)
      6 frames
    3. com.pinterest.secor
      Consumer.run
      1. com.pinterest.secor.reader.MessageReader.<init>(MessageReader.java:70)
      2. com.pinterest.secor.consumer.Consumer.init(Consumer.java:68)
      3. com.pinterest.secor.consumer.Consumer.run(Consumer.java:83)
      3 frames