[
https://issues.apache.org/jira/browse/KAFKA-18963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangzhisheng updated KAFKA-18963:
----------------------------------
Description:
Caused by: org.apache.kafka.common.protocol.types.SchemaException: Error
reading field 'user_data': java.nio.BufferUnderflowException
at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:110)
at
org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignmentV0(ConsumerProtocol.java:286)
at
org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignmentV1(ConsumerProtocol.java:300)
at
org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignment(ConsumerProtocol.java:314)
at
org.apache.kafka.clients.admin.KafkaAdminClient$23.handleResponse(KafkaAdminClient.java:2791)
at
org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.handleResponses(KafkaAdminClient.java:1076)
at
org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1204)
kafka server :2.13-2.7.2
kafka client: 2.13-2.4.1
ConsumerGroupDescription consumerGroup = kafkaAdminClient
.describeConsumerGroups(Lists.newArrayList(groupId)).describedGroups().get(groupId)
.get(5000, TimeUnit.MILLISECONDS);
> Error reading field 'user_data': java.nio.BufferUnderflowException
> ------------------------------------------------------------------
>
> Key: KAFKA-18963
> URL: https://issues.apache.org/jira/browse/KAFKA-18963
> Project: Kafka
> Issue Type: Bug
> Components: clients
> Affects Versions: 2.4.1
> Reporter: zhangzhisheng
> Priority: Major
>
>
> Caused by: org.apache.kafka.common.protocol.types.SchemaException: Error
> reading field 'user_data': java.nio.BufferUnderflowException
> at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:110)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignmentV0(ConsumerProtocol.java:286)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignmentV1(ConsumerProtocol.java:300)
> at
> org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignment(ConsumerProtocol.java:314)
> at
> org.apache.kafka.clients.admin.KafkaAdminClient$23.handleResponse(KafkaAdminClient.java:2791)
> at
> org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.handleResponses(KafkaAdminClient.java:1076)
> at
> org.apache.kafka.clients.admin.KafkaAdminClient$AdminClientRunnable.run(KafkaAdminClient.java:1204)
> kafka server :2.13-2.7.2
> kafka client: 2.13-2.4.1
>
>
> ConsumerGroupDescription consumerGroup = kafkaAdminClient
> .describeConsumerGroups(Lists.newArrayList(groupId)).describedGroups().get(groupId)
> .get(5000, TimeUnit.MILLISECONDS);
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
