ApacheKafka用户组和运行在kubernetes上的微服务是否兼容?

xesrikrc  于 2021-06-08  发布在  Kafka
关注(0)|答案(2)|浏览(291)

到目前为止,我一直在使用springboot应用程序(带有springcloudstream)和kafka,但没有任何支持基础设施(paas)。
因为我们的公司平台是在kubernetes上运行的,所以我们需要将那些spring-boot应用程序迁移到k8s中,以允许应用程序进行扩展等等。显然,每个应用程序将有多个示例,因此我们将为每个应用程序定义一个使用者组,以确保每个消息的唯一传递和处理。
Kafka将在库伯内茨郊外奔跑。
现在我的疑问是:由于部署在k8s上的应用程序是通过抽象底层pod的k8s服务访问的,单个应用程序pod不能直接在k8s集群之外访问,所以kafka不知道如何调用消费者组的单个示例来传递消息,是吗?
我怎样才能让他们一起工作?

tmb3ates

tmb3ates1#

Kafka经纪人不会向客户推送数据。相反,客户端poll()并从代理中提取数据。只要用户可以连接到引导服务器,并且您将kafka代理设置为播发客户端可以连接并轮询()的ip和端口,那么一切都会正常工作。

sqyvllje

sqyvllje2#

spring云数据流能否解决您控制部署示例数量的需求?
而且,openshift还有一个社区发布的spring云数据流服务器:https://github.com/donovanmuller/spring-cloud-dataflow-server-openshift

相关问题