Hi, Thank you for your answer!
I build jar from latest master and rerun the test. Now I see the following
error and stack trace. But I still don't have any ideas what's wrong with my
example. Could you please advice how to fix this error?
[18:14:01,391][ERROR][pool-4-thread-1][root] Message is ignored due to an
error [msg=MessageAndMetadata(test-topic,0,Message(magic = 0, attributes =
0, crc = 3139897862, key = java.nio.HeapByteBuffer[pos=0 lim=4 cap=14],
payload = java.nio.HeapByteBuffer[pos=0 lim=6
cap=6]),126,kafka.serializer.StringDecoder@5e36b9b9,kafka.serializer.StringDecoder@5e36b9b9)]
java.lang.IllegalStateException: Data streamer has been closed.
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.enterBusy(DataStreamerImpl.java:355)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.addDataInternal(DataStreamerImpl.java:550)
at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.addData(DataStreamerImpl.java:604)
at
org.apache.ignite.stream.kafka.KafkaStreamer$1.run(KafkaStreamer.java:180)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
--
View this message in context:
http://apache-ignite-users.70518.x6.nabble.com/Need-help-with-Ignite-KafkaStreamer-tp5186p5284.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.
