实现了 Kafka 消费者桥接。
现在可以从 Kafka 消费消息并将其发布到 MQTT 主题。