[
https://issues.apache.org/jira/browse/KAFKA-1306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13940890#comment-13940890
]
korebantic2 edited comment on KAFKA-1306 at 3/19/14 7:33 PM:
-------------------------------------------------------------
Yup. As you said, it wasn't documented correctly. I change the ID to the
request as you indicated above, and I was able to submit an OffsetCommit
request. I also confirmed the data was stored in zookeeper. So it looks good.
was (Author: korebantic2):
Yup. As you said, it wasn't documented correctly. I change the ID to the
request as you indicated above, and I was able to submit an OffsetCommit
request. I also confirmed the data was stored in zookeeper
/consumers/{consumer_name}/offsets/{topic} . So it looks good.
> Offset commit API, does it work?
> --------------------------------
>
> Key: KAFKA-1306
> URL: https://issues.apache.org/jira/browse/KAFKA-1306
> Project: Kafka
> Issue Type: Bug
> Affects Versions: 0.8.1
> 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)
