Kafka forwarder sanity checker - working as expected