Kafka：コンシューマ接続を終了する

Question

EMSを使用すると、特定のEMSサーバへのすべての接続を確認し、不要な接続をすべて終了することができます。

私の知る限り、私のプロセスと同じ消費者名で私のKafkaトピックを購読しているどこかで望ましくないプロセスがあります。

したがって、私のプロセスはメッセージを受信して​​おらず、この「不正な」プロセスがどこにあるのかわかりません。

このような接続を強制終了するコマンドはありますか？

私はあなたがコンフルエントControl Centerを使用する場合は、各コンシューマ・グループを参照し、各コンシューマ・グループ内のすべてのクライアントができカフカ0.9

Answer 1

を実行しています。それはあなたが "不正な"消費者を特定するのに役立つかもしれません。

そうしないと、新しいグループIDを選択するだけで、他のクライアントが購読しているもの（別のコンシューマーグループに登録されるため）に関係なくなります。

不正なアプリケーションがアクセスを許可されていないトピックを認証して購読できないように、セキュリティとACLを設定する必要があるようです。