Hi, You can use disconnect events/exception, and then use KafkaStreamer.stop. see: https://ignite.apache.org/docs/latest/clustering/connect-client-nodes#client-disconnectedreconnected-events
https://ignite.apache.org/docs/latest/clustering/connect-client-nodes Here look for: While a client is in a disconnected state and an attempt to reconnect is in progress, the Ignite API throws a IgniteClientDisconnectedException KafkaStreamer stop method: https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/stream/kafka/KafkaStreamer.html#stop-- Thanks, Alex -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/
