目前，我有一个API服务端点（用.netcore6C #编写），它将接受消息对象并将其保存到数据库，然后将该消息发布到Kafka topic-2。如何使用我的API服务端点始终侦听/监视并连接到Kafka topic-1，以及一旦新消息出现在kafka topic-1中，就立即查找新消息，然后逐个使用消息并将消息传递到API服务端点？
rekjcdws1#
为此，您将使用Kafka消费者，而不是“API端点”。https://github.com/confluentinc/confluent-kafka-dotnet
v7pvogib2#
感谢您分享您的想法。我能够使Kafka消费功能在我的本地主机上工作。出于测试目的，我将把我的代码部署到Azure开发环境中的资源组中的一个Pod，作为AKS中的映像，并验证行为。如果一切都按预期运行，我将把它提升到QA环境。谢谢瓦姆希
2条答案
按热度按时间rekjcdws1#
为此，您将使用Kafka消费者，而不是“API端点”。
https://github.com/confluentinc/confluent-kafka-dotnet
v7pvogib2#
感谢您分享您的想法。我能够使Kafka消费功能在我的本地主机上工作。出于测试目的，我将把我的代码部署到Azure开发环境中的资源组中的一个Pod，作为AKS中的映像，并验证行为。
如果一切都按预期运行，我将把它提升到QA环境。
谢谢瓦姆希