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)