2016-11-30 4 views
4

kafkaの認証を設定する場合、documentには、kafkaサーバを起動するときにJVMパラメータを追加する必要があることが記載されています。以下のように:私たちは、サーバーを起動するために、ビン/ kafka-server-start.shを使用しているのでkafkaにJVMパラメータを追加するには?

-Djava.security.auth.login.config=/etc/kafka/kafka_server_jaas.conf

、文書がどこJVMパラメータを指定する言及しませんでした。

kafka-server-start.shまたはkafka-server-class.shを変更することはお勧めできません。最初にパラメータを追加する正しい方法は何でしょうか?

答えて

7

これには、KAFKA_OPTS環境変数を使用することをお勧めします。

この環境変数はKafkaによって認識され、デフォルトで空の文字列(=設定なし)になります。カフカのソースコードにbin/kafka-run-class.shから次のコードスニペットを参照してください:

# Generic jvm settings you want to add 
if [ -z "$KAFKA_OPTS" ]; then 
    KAFKA_OPTS="" 
fi 

したがって、たとえば、あなたが行うことができます:

$ export KAFKA_OPTS="-Djava.security.auth.login.config=/etc/kafka/kafka_server_jaas.conf" 
$ bin/kafka-server-start.sh 

または

$ KAFKA_OPTS="-Djava.security.auth.login.config=/etc/kafka/kafka_server_jaas.conf" bin/kafka-server-start.sh 
関連する問題