I have an application with multi-cluster binder that reads from one Kafka cluster and produces message