java.io.IOException: Unable to find a new Kafka lead Broker after 3 attempts. Unable to proceed.

GitHub | Alex-Cook4 | 1 year 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 SimpleConsumer requires key output attribute

    GitHub | 1 year ago | Alex-Cook4
    java.io.IOException: Unable to find a new Kafka lead Broker after 3 attempts. Unable to proceed.

    Root Cause Analysis

    1. java.io.IOException

      Unable to find a new Kafka lead Broker after 3 attempts. Unable to proceed.

      at com.ibm.streamsx.messaging.kafka.SimpleConsumerClient.findNewLeader()
    2. com.ibm.streamsx
      SimpleConsumerClient.findNewLeader
      1. com.ibm.streamsx.messaging.kafka.SimpleConsumerClient.findNewLeader(SimpleConsumerClient.java:166)
      1 frame