首页 文章

如何使用.net客户端生成和使用来自kafka的消息

提问于
浏览
3

我是kafka,docker和kubernetes的新手 . 我试图在minikube中运行单节点或多节点kafka集群,并使用.net控制台应用程序生成/使用来自kafka代理的消息 .

任何人都可以指向/指出.net应用程序的任何工作解决方案吗?使用哪个我可以创建一个简单的POC,它能够向/从kafka经纪人发送/接收消息?

我花了太多时间使用solsson/kafka-persistent和汇总简单的 生产环境 者/消费者代码实现这一点,但我只能在minikube集群中访问主题,在集群之外kafka经纪人是不可见的 . 我找到了同一个Yolean/kubernetes-kafka的另一个解决方案但是因为我无法正确理解并且无法实现一个工作的简单控制台应用程序,它可以从kubernetes外部生成/使用来自kafka主题的消息 .

如果有人可以帮助我使用一些有效的解决方案,或者指导我使用.net客户端逐步实现kafka消息服务,那将会非常有帮助 .

提前致谢!

1 回答

  • 0

    将Kafka暴露在minikube之外(Kubernetes)是一个非常复杂的问题,因为你总是可以获得未经发布的IP地址(可以随时更改的内部地址)作为Kafka经纪人的答案 . 因此,最好的方法是在Kafka附近的Kubernetes集群内使用.net客户端 . 然后你将拥有Kafka和.net客户端,例如Confluent's在同一个网络中 . 我建议你阅读this article,它与GKE有关,但无论如何你可以用它作为例子,并在minikube中运行相同的配置 .

相关问题