.net - 如何使用.net客户端向和从kafka产生和使用消息

标签 .net docker apache-kafka kubernetes confluent-platform

我对kafka,docker和kubernetes很陌生。我试图在minikube中运行单节点或多节点kafka集群,并使用.net控制台应用程序生成与使用kafka代理之间的消息。

谁能指导我/指向.net应用程序的任何有效解决方案?通过它我可以创建一个简单的POC,该POC可以向/从kafka经纪人发送/接收消息?

我花了很多时间来使用solsson/kafka-persistent和融合的简单生产者/消费者代码来实现这一点,但是我只能访问minikube集群中的主题,而集群kafka代理之外是不可见的。我找到了针对同一Yolean/kubernetes-kafka的另一种解决方案,但是由于我不熟悉kubernetes /网络和yaml,因此我无法正确理解并且无法实现一个可以从外部向kafka主题生成消息/从中获取消息的工作的简单控制台应用程序kubernetes。

如果有人可以帮助我提供一些可行的解决方案或指导我使用.net客户端逐步实现kafka消息传递服务,这将非常有帮助。

提前致谢!

最佳答案

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

关于.net - 如何使用.net客户端向和从kafka产生和使用消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49559791/

相关文章:

docker - 如何访问 Dockerfile 中的 Docker 构建上下文路径

docker - 如何在 CLI(命令行界面)中将参数传递给 docker run?

php - 在多个实例中运行 Laravel 作业

oracle - 如何在Docker中连接到外部Oracle数据库

c# - 无法向 ServiceControl 注册端点启动

c# - 将自定义对象传递给 Web 服务

c# - .NET 中的 IoC 是什么

c# - 为什么在没有代码更改的干净构建后会生成不同的 dll?

hadoop - Kafka console producer 在 Hortonworks HDP 2.3 Sandbox 中出错

java - ExecutorService 关闭 - Kafka