Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Consumer error #1

Closed
amsz opened this issue Nov 22, 2013 · 3 comments
Closed

Consumer error #1

amsz opened this issue Nov 22, 2013 · 3 comments

Comments

@amsz
Copy link

amsz commented Nov 22, 2013

I run example/consumer.js to connect 0.8.0 Beta1 Kafka server, kafka print some error :

[2013-11-22 13:59:11,573] INFO Closing socket connection to /10.15.100.58. (kafka.network.Processor)
[2013-11-22 13:59:13,677] ERROR Closing socket for /10.15.100.58 because of error (kafka.network.Processor)
kafka.common.KafkaException: Wrong request type 9
    at kafka.api.RequestKeys$.deserializerForKey(RequestKeys.scala:53)
    at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:49)
    at kafka.network.Processor.read(SocketServer.scala:345)
    at kafka.network.Processor.run(SocketServer.scala:245)
    at java.lang.Thread.run(Thread.java:722)

version is 0.0.4.
@haio
Copy link
Member

haio commented Nov 22, 2013

Maybe this is the bug of Kafka 0.8.0 Beta1, this version may not have OffsetCommit API whose request type is 9, so you should try the latest Kafka: https://github.com/apache/kafka/tree/trunk.

@crzidea
Copy link
Member

crzidea commented Nov 22, 2013

Year, it is a bug of early version of 0.8. Pull latest version from https://git-wip-us.apache.org/repos/asf/kafka.git, and you will not got this error.

@amsz
Copy link
Author

amsz commented Nov 22, 2013

Thanks for your quickly reply, it work fine with trunk version.

@amsz amsz closed this as completed Nov 22, 2013
@haio haio mentioned this issue Dec 4, 2013
Closed
@azriel46d azriel46d mentioned this issue Dec 14, 2015
Open
shaikh-shahid added a commit to shaikh-shahid/kafka-node that referenced this issue Oct 24, 2016
@shaikh-shahid
Update client.js
e1fe46c 
Fixes for build failure SOHU-Co#1.
hyperlink pushed a commit that referenced this issue Oct 26, 2016
@shaikh-shahid @hyperlink
Kafka topics should not contain special characters (#492)
85f94a9 
* Kafka topics should not contain special characters

This is my observation while playing with createTopics function. I later realised that topic names which I am creating contains special characters such as :,// etc which is causing the issue. I tried without them and it works. It does work with other number and string combinations so no test required for that.

Hope this PR is help.

* Update client.js

Fixes for build failure #1.

* Update client.js

Fixed for build #2.

* Update client.js

Fixes for build #3.

* Validating the topics using util function

* Build fix

* Update client.js

Updating the name of function as per changes in pull req no 17.

* Handling async nature of validation.

Build fix.

* Update client.js

Build fix.

* Update client.js

For build fix.
@iamsahil1989 iamsahil1989 mentioned this issue Nov 10, 2017
Closed
@tcollinsworth tcollinsworth mentioned this issue Mar 8, 2018
Open
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
3 participants
@amsz @haio @crzidea