Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14246 Update threading model for Consumer
  3. KAFKA-15887

Autocommit during close consistently fails with exception in background thread

    XMLWordPrintableJSON

Details

    Description

      when I run AsyncKafkaConsumerTest I get this every time I call close:

      java.lang.IndexOutOfBoundsException: Index: 0
      	at java.base/java.util.Collections$EmptyList.get(Collections.java:4483)
      	at java.base/java.util.Collections$UnmodifiableList.get(Collections.java:1310)
      	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.findCoordinatorSync(ConsumerNetworkThread.java:302)
      	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.ensureCoordinatorReady(ConsumerNetworkThread.java:288)
      	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.maybeAutoCommitAndLeaveGroup(ConsumerNetworkThread.java:276)
      	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.cleanup(ConsumerNetworkThread.java:257)
      	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkThread.run(ConsumerNetworkThread.java:101)
      

      Attachments

        Issue Links

          Activity

            People

              pnee Philip Nee
              lucasbru Lucas Brutschy
              Votes:
              0 Vote for this issue
              Watchers:
              0 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: