如何将JVM参数添加到kafka？

Question

在为kafka配置身份验证时,该文档提到在启动kafka服务器时需要添加JVM参数.喜欢:

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

由于我们使用bin/kafka-server-start.sh来启动服务器,因此该文档没有提到指定JVM参数的位置.

修改kafka-server-start.sh或kafka-server-class.sh不是一个好主意,那么在开始时添加参数的正确方法是什么？

Answer 1

我建议使用KAFKA_OPTS环境变量.

此环境变量由Kafka识别,默认为空字符串(=无设置).请参阅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