You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@ignite.apache.org by Anil <an...@gmail.com> on 2016/12/01 10:48:11 UTC

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

Re: Cache stopped exception with KafkaStreamer

Posted by vkulichenko <va...@gmail.com>.

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.