Hi all, I'm having some problems dealing with the KafkaStreamer. I have a deployment with a streamer (client node) that consumes records from a Kafka topic, and a data node (cache storage).
If for any reason, the cache node crashes or simple restarts, the client node gets disconnected, but the KafkaStreamer keeps pulling records and tries to push to the cache. Is there a recommended way to stop the kafkaStreamer on client disconnection and resume once the connection is established again? -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/
