You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2019/10/24 04:40:00 UTC
[jira] [Resolved] (KAFKA-8914) Setting GROUP_INSTANCE_ID_CONFIG
leads to a protobuf error
[ https://issues.apache.org/jira/browse/KAFKA-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Matthias J. Sax resolved KAFKA-8914.
------------------------------------
Resolution: Duplicate
Thanks for the follow up [~igmar]. Closing this as duplicate. Btw: 2.3.1 is about to be released (maybe this or next week).
> Setting GROUP_INSTANCE_ID_CONFIG leads to a protobuf error
> ----------------------------------------------------------
>
> Key: KAFKA-8914
> URL: https://issues.apache.org/jira/browse/KAFKA-8914
> Project: Kafka
> Issue Type: Bug
> Components: clients
> Affects Versions: 2.3.0
> Reporter: Igamr Palsenberg
> Priority: Major
>
>
> Setting ConsumerConfig.GROUP_INSTANCE_ID_CONFIG (group.instance.id) to any value (I tried valid numbers and just some string values) will result in :
> org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'version': java.nio.BufferUnderflowExceptiong.apache.kafka.common.protocol.types.SchemaException: Error reading field 'version': java.nio.BufferUnderflowException at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:110) at org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignment(ConsumerProtocol.java:106) at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.onJoinComplete(ConsumerCoordinator.java:262) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:424) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:358) at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:353) at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1251) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1216) at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1201)
>
> Kafka broker :
> Kafka 2.3.0, installed using Brew. Default config, except the bind IP, that is set explicitly to localhost.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)