0

KStreamsベースのアプリケーションで問題が発生しています。アプリケーションは一度実行され、停止/再起動すると「スタック」し、作成したさまざまなトピックを削除するまで進行しません。これは毎回ではありませんが、頻繁に発生します。

通常、これは、新しい (er) バージョンを作業用 VM にコピーするときに発生します (速度上の理由から、kafka クラスターと同じサブネット内にあります)。

それがくさびになったとき、私は見るでしょう。

  1. "接続"： org.apache.zookeeper.ZooKeeper - Initiating client connection
  2. "クライアント"：[StreamThread-1] INFO o.a.k.s.p.internals.StreamTask - Creating restoration consumer client
  3. "Ping" : これらが表示され、アプリが正常にシャットダウンされません。それは殺されなければなりません。

これらのケースのいずれにおいても、通常、メッセージは無期限に繰り返されます (まあ、少なくとも昼食と会議の間ずっと。つまり、長すぎます)。

これが発生する前に、アプリは「正常に」シャットダウンしています。

私は何を間違っていますか？

編集：

この最新の時間-20分後、一連のエラーが発生しました：

org.apache.kafka.common.errors.TimeoutException: ブローカーからのメタデータの要求中にタイムアウトが発生したため、101 レコードを含むバッチが期限切れになりました

に続く：

org.apache.kafka.clients.consumer.CommitFailedException: グループがすでに再調整され、パーティションが別のメンバーに割り当てられているため、コミットを完了できません

-->他にメンバーがいないので、これは良いトリックです。

4

1 に答える 1