グループ（Kafka）のコーディネーターに死を通知する

Question

私のサービスの1つは数時間前に動作を停止しました。私はサーバーを再起動しましたが、この消費者プロセスは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

本当にその奇妙な。コンシューマーのもう1つを再起動しなければならず、再起動後、もう1秒前に正常に動作していた他のコンシューマーも同じエラーを記録しています。 基本的に、何らかの理由でカフカに接続できない2つの消費者プロセスがあります。

Answer 1

私自身の質問に答える：

最後にそれを働かせました。これはブローカー問題または消費者問題ではありませんでした。 何が起こったのか、我々は夜8時30分ごろ、カフカの両方のブローカーにファイアウォールを有効にしました。すでにカフカとつながっていた消費者はうまく働いていた。ただし、これらのコンシューマの1つが再起動されると、コーディネータに接続できるようになりました。 Kafkaブローカーの両方でファイアウォールを無効にし、すぐにデータが消費者に中継されました。それは一時的な修正ATMですが、少なくとも私たちは何かを持っています。