ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alexey <j...@list.ru>
Subject Re: Need help with Ignite KafkaStreamer
Date Mon, 30 May 2016 12:35:45 GMT
I removed  'try (...) {}' block and now I don't see any errors in the code.
I added some logs in KafkaStreamer and according to the log adding data to
steamer finished without exception and any errors. But unfortunately the
cache that used for streamer is still empty.

[15:12:44,450][WARN ][pool-4-thread-1][root] Cache name KafkaCache
[15:12:44,450][WARN ][pool-4-thread-1][root] Msg.key key1
[15:12:44,451][WARN ][pool-4-thread-1][root] Msg.message test-msg2
[15:12:44,451][WARN ][pool-4-thread-1][root] Success!!!

I tried to add receiver (or visitor) to the streamer, check the size of
cache after sending kafka message but it seems streamer does not receive any
How can I check that KafkaStreamer works properly?

View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Need-help-with-Ignite-KafkaStreamer-tp5186p5312.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.

View raw message