MQTT filter to Kafka