apache-kafka - 在Kubernetes上运行的Apache Kafka消费者组和微服务是否兼容？

Question

到目前为止，我一直在使用Spring Boot应用程序(带有Spring Cloud Stream)和Kafka，而没有任何支持基础架构(PaaS)。

由于我们的企业平台在Kubernetes上运行，因此我们需要将这些Spring Boot应用程序移至K8中以允许应用程序扩展等。显然，每个应用程序都有一个以上的实例，因此我们将为每个应用程序定义一个使用者组，以确保唯一地传递和处理每条消息。

Kafka将在Kubernetes之外运行。

现在我的疑问是:由于通过抽象基础Pod的k8s服务访问了部署在k8s上的应用程序，并且不能直接在k8s集群外部访问单个应用程序Pod，因此Kafka将不知道如何调用以下实例的单个实例:消费者群体传递消息，对吗？

如何使它们一起工作？

Answer 1

卡夫卡经纪人不会将数据推送到客户端。而是客户端poll()并从代理中提取数据。只要使用者可以连接到引导服务器，并且您将Kafka代理设置为播发客户端可以连接到的IP和端口并进行poll()，则一切正常。