kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jun Rao (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-1306) Offset commit API, does it work?
Date Wed, 19 Mar 2014 04:12:44 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-1306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13940140#comment-13940140
] 

Jun Rao commented on KAFKA-1306:
--------------------------------

It seems that you put in the wrong request id. The id for OffsetCommit is 8, instead of 6.

> 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)

Mime
View raw message