Re: Cache stopped exception with KafkaStreamer
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.
Cache stopped exception with KafkaStreamer
Hi, I am using KafkaStreamer to populate the data into cache. i see following message in logs java.lang.IllegalStateException: Grid is in invalid state to perform this operation. It either not started yet or has already being or have stopped [gridName=vertx.ignite.node.7f903539-ac5a-4cd1-9425-c06f4b45c56d, state=STOPPED] I see cluster looks good and have enough resources. How to handle cache close exception in case of Kafka streamer ? Thanks