Hi,
I'm receiving an error when trying to read consumer offsets using the
kafka-consumer-groups script.
The error occurs when I consume using the pykafka library, but not when
I consume with the kafka-console-consumer (which works fine)
Kafka version: 0.9.0.1
Scala version: 2.10
PyKafka version: 2.3.1
Here's the Error:
/kafka/bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092
--new-consumer --group test --describe
Error while executing consumer group command Error reading field
'user_data': java.nio.BufferUnderflowException
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:71)
at
org.apache.kafka.clients.consumer.internals.ConsumerProtocol.deserializeAssignment(ConsumerProtocol.java:109)
at
kafka.admin.AdminClient$$anonfun$describeConsumerGroup$1.apply(AdminClient.scala:161)
at
kafka.admin.AdminClient$$anonfun$describeConsumerGroup$1.apply(AdminClient.scala:160)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
at scala.collection.immutable.List.foreach(List.scala:318)
at
scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
at scala.collection.AbstractTraversable.map(Traversable.scala:105)
at kafka.admin.AdminClient.describeConsumerGroup(AdminClient.scala:160)
at
kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describeGroup(ConsumerGroupCommand.scala:314)
at
kafka.admin.ConsumerGroupCommand$ConsumerGroupService$class.describe(ConsumerGroupCommand.scala:84)
at
kafka.admin.ConsumerGroupCommand$KafkaConsumerGroupService.describe(ConsumerGroupCommand.scala:302)
at
kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:63)
at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
Can anyone advise if this is my error (I'm doing something wrong) or if
it's worth reporting a bug (to either kafka or pykafka or both).
Regards,
Mike
--
Mike Tonks
HeadForwards
