Javaを使用してKafkaからACLSを削除する方法

Javaプログラムを使用してKAfkaからACLSを削除しようとしています。このセキュリティチェックや強制削除オプションを無効にするのいずれかのために私が探していますJavaを使用してKafkaからACLSを削除する方法

：しかし、除去にセキュリティチェックが

がACLを削除してもよろしいです求めています。

2016-12-20 Raju

強制削除オプションはありません。これは、Console.readLine（）。equalsIgnoreCase（ "y"）を呼び出して、コンソールから確認することを期待します。 – amethystic

あなたのクイックレースのおかげで、私は問題を解決できました。 – Raju

カフカ0.10.1.0から0.10.0.0にアップグレードされました。ここで、強制削除オプションはAclCommand（スカラコンポーネント）で使用できます。 --removeの後に--forceパラメータを追加します。正しく動作する構文： String [] cmdPArm = {"--authorizer-properties"、 "zookeeper.connect = localhost：2181"、 "--remove"、 "--force"、 "--allow-principal"、「ユーザー：*」、「 - ホスト - ホスト」、「17.129.0.99」、「 - 操作」、「読み取り」、「 - 操作」、「書き込み」、 "--topic"、 "myTopic" }; AclCommand.main（cmdPArm）;

出典

2016-12-20 16:26:23 Raju

私の解決策を掲載しました。はい、Kafka 0.10.1.0はすべてのプロンプトを避けるために "--force"オプションを提供しています。 – amethystic

Javaを使用してKafkaからACLSを削除する方法

答えて

関連する問題