我有三个豆荚在kubernetes节点。
pod-1:单节点kafka代理
pod-2:单节点zookeeper
pod-3:几个支持kafka的spring-boot应用程序
早些时候,我们在docker上有类似的设置。在我们转到kubernetes安装程序之后,pod-3中的所有应用程序都开始出现这种错误
[2020-01-23 06:37:05.267] :: [INFO ] :: o.a.k.c.c.i.AbstractCoordinator.markCoordinatorUnknown.729 :: [Consumer clientId=consumer-2, groupId=OperationResponseConsumer] Group coordinator 9.x.x.x:31865 (id: 2147483646 rack: null) is unavailable or invalid, will attempt rediscovery
[2020-01-23 06:37:05.386] :: [INFO ] :: o.a.k.c.c.i.AbstractCoordinator.onSuccess.677 :: [Consumer clientId=consumer-2, groupId=OperationResponseConsumer] Discovered group coordinator 9.x.x.x:31865 (id: 2147483646 rack: null)
这种情况不断循环,没有一个消费者能抓住主题。在最好的情况下,消费者群体的依恋是断断续续的。这会是什么?
Kafka:2.2Spring Boot:2.1.5
----编辑
在经纪方面,我一直得到这些日志
[2020-01-23 07:34:15,083] INFO [GroupCoordinator 1]: Member consumer-2-d2102198-df08-4009-9ba2-85350a2e9240 in group openapi-handler-consumer has failed, removing it from the group (kafka.coordinator.group.GroupCoordinator)
[2020-01-23 07:34:15,083] INFO [GroupCoordinator 1]: Preparing to rebalance group openapi-handler-consumer in state PreparingRebalance with old generation 3 (__consumer_offsets-24) (reason: removing member consumer-2-d2102198-df08-4009-9ba2-85350a2e9240 on heartbeat expiration) (kafka.coordinator.group.GroupCoordinator)
1条答案
按热度按时间3okqufwl1#
---编辑
下面是我们用于kafka的部署描述符
Kafka服务公司
消费者应用程序部署: