Created
October 26, 2011 14:53
-
-
Save steeve/1316588 to your computer and use it in GitHub Desktop.
Kafka Send Exception
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| def string_to_message(str) | |
| Java::KafkaMessage::Message.new(str.to_java_bytes) | |
| end | |
| options = { | |
| "zk.connect" => "127.0.0.1:2181" | |
| } | |
| @producer = Java::KafkaJavaapiProducer::Producer.new( | |
| Java::KafkaProducer::ProducerConfig.new( | |
| hash_to_properties(options) | |
| ) | |
| ) | |
| @producer.send(Java::KafkaJavaapiProducer::ProducerData.new(group_id, msg)) |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| NativeException (java.lang.NullPointerException: null): | |
| kafka/network/BoundedByteBufferSend.scala:48:in `writeTo' | |
| kafka/network/Transmission.scala:76:in `writeCompletely' | |
| kafka/network/BoundedByteBufferSend.scala:25:in `writeCompletely' | |
| kafka/producer/SyncProducer.scala:88:in `liftedTree1$1' | |
| kafka/producer/SyncProducer.scala:87:in `send' | |
| kafka/producer/SyncProducer.scala:117:in `send' | |
| kafka/producer/ProducerPool.scala:116:in `apply$mcVI$sp' | |
| kafka/producer/ProducerPool.scala:102:in `apply' | |
| kafka/producer/ProducerPool.scala:102:in `apply' | |
| scala/collection/mutable/ResizableArray.scala:57:in `foreach' | |
| scala/collection/mutable/ArrayBuffer.scala:43:in `foreach' | |
| kafka/producer/ProducerPool.scala:102:in `send' | |
| kafka/producer/Producer.scala:142:in `zkSend' | |
| kafka/producer/Producer.scala:104:in `send' | |
| kafka/javaapi/producer/Producer.scala:104:in `send' |
Author
Yes I think it was resolved, by updating Kafka at the time!
…On 26 juin 2012, at 03:13, Jim Lim Jiunn Haur ***@***.*** wrote:
Hey, out of curiosity, did you ever solve this issue?
---
Reply to this email directly or view it on GitHub:
https://gist.github.com/1316588
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Hey, out of curiosity, did you ever solve this issue?