korebantic2 created KAFKA-1306:
----------------------------------
Summary: Offset commit API, does it work?
Key: KAFKA-1306
URL: https://issues.apache.org/jira/browse/KAFKA-1306
Project: Kafka
Issue Type: Bug
Reporter: korebantic2
I followed this guide very carefully
https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol
and patched the ruby client Poseidon. Whenever I submit an OffsetCommitRequest,
I receive the following error in the kafka logs:
{noformat}
23:07:33 kafka-b0.1 | java.nio.BufferUnderflowException
23:07:33 kafka-b0.1 | at java.nio.HeapByteBuffer.get(HeapByteBuffer.java:145)
23:07:33 kafka-b0.1 | at java.nio.ByteBuffer.get(ByteBuffer.java:694)
23:07:33 kafka-b0.1 | at
kafka.api.ApiUtils$.readShortString(ApiUtils.scala:38)
23:07:33 kafka-b0.1 | at
kafka.api.UpdateMetadataRequest$$anonfun$readFrom$1.apply(UpdateMetadataRequest.scala:43)
23:07:33 kafka-b0.1 | at
kafka.api.UpdateMetadataRequest$$anonfun$readFrom$1.apply(UpdateMetadataRequest.scala:42)
23:07:33 kafka-b0.1 | at
scala.collection.immutable.Range.foreach(Range.scala:78)
23:07:33 kafka-b0.1 | at
kafka.api.UpdateMetadataRequest$.readFrom(UpdateMetadataRequest.scala:42)
23:07:33 kafka-b0.1 | at
kafka.api.RequestKeys$$anonfun$7.apply(RequestKeys.scala:42)
23:07:33 kafka-b0.1 | at
kafka.api.RequestKeys$$anonfun$7.apply(RequestKeys.scala:42)
23:07:33 kafka-b0.1 | at
kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:50)
23:07:33 kafka-b0.1 | at kafka.network.Processor.read(SocketServer.scala:353)
23:07:33 kafka-b0.1 | at kafka.network.Processor.run(SocketServer.scala:245)
23:07:33 kafka-b0.1 | at java.lang.Thread.run(Thread.java:724)
{/noformat}
The binary data for the request looks as follows:
{noformat}
\x00\x06\x00\x00\x00\x00\x00\x02\x00\x02p1\x00\x03cg1\x00\x00\x00\x01\x00\x05repl5\x00\x00\x00\x01\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x01\x00\x04meta
{/noformat}
Thinking that I failed to understand how to formulate the binary request
correctly, I downloaded sarama, the go kafka library. Using its API to make the
request, I also received the same error. Here's an example:
https://github.com/talbright/saramit
--
This message was sent by Atlassian JIRA
(v6.2#6252)
