Make plugins tolerant to Kafka cluster node failures