Anil, This means that you stopped the embedded client node before it loaded all the data into the cache. Ignite and IgniteDataStreamer provided via setIgnite() and setStreamer methods should not be closed before the Kafka streamer is closed.
See the example here: https://apacheignite-mix.readme.io/docs/kafka-streamer -Val -- View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Cache-stopped-exception-with-KafkaStreamer-tp9326p9348.html Sent from the Apache Ignite Users mailing list archive at Nabble.com.
