我有一个解决方案，它使用消息传递系统（QPID）在应用程序之间传递消息。 一个应用程序从外部服务器接收有关数千种产品的大量实时信息，对其进行处理并将处理后的信息发送到以产品 id 作为主题的主题（命名产品）。如果其他应用程序（消费者）想要显示特定产品的实时信息，他们只需要监听主题（产品）中的特定主题（产品ID）。使用该机制（主题），他们仅接收有关该产品的信息。 QPID 主题
拥有数千种产品，是否可以使用 kafka 实现类似的方法？如果是这样，实现这一目标的最佳方法是什么？
我已经检查过我们是否可以使用记录键实现类似的行为，但我还没有找到合适的解决方案。
您可以将信息放入每个产品的单独 Kafka 主题中。