是否可以使用 MQTT-Proxy form Confluent 写入 Kafka-Topic 上的特定分区？

【问题标题】：Is it possible to write to a specifiv Partition on a Kafka-Topic with MQTT-Proxy from Confluent?是否可以使用 MQTT-Proxy form Confluent 写入 Kafka-Topic 上的特定分区？
【发布时间】：2021-08-30 11:42:15
【问题描述】：

也许有人可以帮我解决一个小问题。有没有办法使用 Confluent 的 MQTT-Proxy 中内置的 Producer 配置 Key Partitioning？

只有一个 Topic-Mapping-Property，但我还没有找到如何将 MQTT-Proxy 与按 Key 分区的 Topic 一起使用。我可以在 MQTT 消息中包含 Kafka 协议的密钥吗？

谢谢各位。

【问题讨论】：

标签： apache-kafka mqtt confluent-platform confluent-cloud

【解决方案1】：

好的……对不起。找到零件：

由于 Kafka 中的主题命名规则比 MQTT 中的更严格，因此不每个 MQTT 主题都可以映射到一个 Kafka 主题。因此，MQTT 主题是 由 Kafka 中的消息键表示，单个 Kafka 主题可能包含多个 MQTT 主题的消息。

https://www.confluent.de/blog/iot-streaming-use-cases-with-kafka-mqtt-confluent-and-waterstream/

【讨论】：