私は kafka-0.8.1.1 バージョンを使用していますが、このバージョンでは自動再接続は Java コード経由では機能しません。プロパティファイルを次のように持っています
props.put("zookeeper.connect", "zoo1:2181,zoo2:2181");
props.put("group.id", KAFKA_GROUPID);
props.put("zookeeper.session.timeout.ms", "10000");
props.put("zookeeper.sync.time.ms", "200");
props.put("auto.commit.interval.ms", "1000");
コンシューマースレッドを開始している間、それはカフカサーバーに接続されています。サーバーを実行しているスレッドの間にカフカサーバーへの接続が2時間失われます。再接続すると、カフカコンシューマーはメッセージを受信せず、エラーもスローしませんフロー。
接続が失われたことを検出して、消費者スレッドを自動的に再接続するにはどうすればよいでしょうか。
前もって感謝します