You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ismail Mekni (Jira)" <ji...@apache.org> on 2020/09/07 11:19:00 UTC
[jira] [Created] (KAFKA-10464) Kafka client throws
IndexOutOfBoundsException when polling messages
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)