그룹 (Kafka)의 코디네이터 표시

Question

몇 시간 전에 내 서비스 중 하나가 작동을 멈췄습니다. 서버를 다시 시작했지만이 소비자 프로세스가 Kafka에 등록하지 않았습니다. 소비자가 시작될 때 표시되는 내용입니다.

2017-04-21 10:22:54.887 INFO 18036 --- [afka-consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : Revoking previously assigned partitions [] for group mysql-conversions-group 
2017-04-21 10:22:54.890 INFO 18036 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer : partitions revoked:[] 
2017-04-21 10:22:54.890 INFO 18036 --- [afka-consumer-1] o.a.k.c.c.internals.AbstractCoordinator : (Re-)joining group mysql-conversions-group 
2017-04-21 10:22:54.915 INFO 18036 --- [afka-consumer-1] o.a.k.c.c.internals.AbstractCoordinator : Marking the coordinator li819-138.members.linode.com:9092 (id: 2147483646 rack: null) dead for group mysql-conversions-group 

저는 4 개의 서로 다른 소비자 그룹이 있으며 잘 운영되고 있습니다. 이견있는 사람?

UPDATE

그 이상한 정말. 우리는 Consumer 중 다른 하나를 다시 시작해야했고, 다시 시작한 후 잠시 정상적으로 작동하고 있던 다른 소비자는 이제 같은 오류를 기록합니다. 기본적으로 카프카에 연결할 수없는 2 개의 소비자 프로세스가 있습니다.

Answer 1

내 질문에 대답 :

마지막으로 작동하도록했습니다. 이것은 중개인 문제 또는 소비자 문제가 아니 었습니다. 무슨 일이 있었는지, 우리는 밤 8시 30 분경 카프카 중개인 모두에게 방화벽을 활성화 시켰습니다. 이미 카프카와 연결된 소비자들은 잘 작동하고있었습니다. 그러나 이러한 소비자 중 하나가 다시 시작되면 코디네이터에 연결할 수 있습니다. 우리는 Kafka 중개인 모두의 방화벽을 해제했으며 데이터는 즉시 소비자에게 전달되었습니다. 임시 수정 ATM이지만 최소한 우리는 뭔가를 가지고 있습니다.