[jira] [Created] (KAFKA-10464) Kafka client throws IndexOutOfBoundsException when polling messages

["Ismail Mekni (Jira)" <ji...@apache.org>]

Ismail Mekni created KAFKA-10464:
------------------------------------

             Summary: Kafka client throws IndexOutOfBoundsException when polling messages
                 Key: KAFKA-10464
                 URL: https://issues.apache.org/jira/browse/KAFKA-10464
             Project: Kafka
          Issue Type: Bug
          Components: clients
    Affects Versions: 2.0.0
            Reporter: Ismail Mekni


When polling records from Kafka cluster with three brokers, Kafka client throws an IndexOutOfBoundsException:


{code:java}
java.lang.IndexOutOfBoundsException: Index: 1, Size: 1 at java.util.ArrayList.rangeCheck(ArrayList.java:653) at java.util.ArrayList.get(ArrayList.java:429) at org.apache.kafka.common.metrics.stats.SampledStat.current(SampledStat.java:81) at org.apache.kafka.common.metrics.stats.SampledStat.record(SampledStat.java:48) at org.apache.kafka.common.metrics.stats.Rate.record(Rate.java:61) at org.apache.kafka.common.metrics.stats.Meter.record(Meter.java:79) at org.apache.kafka.common.metrics.Sensor.record(Sensor.java:182) at org.apache.kafka.common.metrics.Sensor.record(Sensor.java:172) at org.apache.kafka.common.metrics.Sensor.record(Sensor.java:159) at org.apache.kafka.common.metrics.Sensor.record(Sensor.java:141) at org.apache.kafka.common.network.Selector.doClose(Selector.java:758) at org.apache.kafka.common.network.Selector.close(Selector.java:739) at org.apache.kafka.common.network.Selector.maybeCloseOldestConnection(Selector.java:647) at org.apache.kafka.common.network.Selector.poll(Selector.java:440) at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:510) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:271) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:242) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:218) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:230) at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:314) at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1218) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1181) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1115){code}

Code:



 
{code:java}
ConsumerRecords<String, String> records = consumer.poll(pollTimeOut);
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)