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

Question

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

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

多谢你们。

score 0 · Accepted Answer

好的，对不起。找到部分：

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

1 回答 1