如何为Kafka设置Java选项？

Question

我一直在试验与Kafka和看到从主网站上的留档，你可以设置不同的选项为jvm像堆大小和垃圾收集器，它使用：

http://kafka.apache.org/documentation.html#java

然而，它没有说明如何/在哪里设置这些选项。该应用程序附带了一个/config目录，其中包含许多用于配置的文件，但没有一个是用于Java的。它还附带了一个/bin目录，其中包含了一堆Kafka的脚本，但是同样，没有真正说明如何配置Java。

所以我的问题是，如何配置Kafka使用的Java选项？它是通过文件完成的还是有不同的方法？

Answer 1

查看kafka-run-classh.sh-kafka使用以下变量：

• $KAFKA_堆_OPTS
• $KAFKA_JVM_PERFORMANCE_OPTS
• $KAFKA_GC_LOG_OPTS
• $KAFKA_JMX_OPTS
• $KAFKA_LOG4J_OPTS

您可以通过以下方式运行它：

export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G" 
export KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=12346 -Dcom.sun.management.jmxremote.rmi.port=12346 -Dcom.sun.management.jmxremote.local.only=false -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false" 
bin/kafka-server-start.sh -daemon config/server.properties

Answer 2

另一种方法是修改/bin/kafka-server-start.sh中写入的信息：

export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"

或者在/bin/kafka-run-class.sh中：

KAFKA_JVM_PERFORMANCE_OPTS="-server -XX:+UseCompressedOops -XX:+UseParNewGC -XX:+UseConcMarkSweepGC -XX:+CMSClassUnloadingEnabled -XX:+CMSScavengeBeforeRemark -XX:+DisableExplicitGC -Djava.awt.headless=true"

Answer 3

强烈建议不要修改 bin 目录中的脚本。将 Kafka 升级到下一个版本时，提取新的二进制文件将覆盖脚本中所做的更改。

首选的方法应该是在脚本外部设置环境变量KAFKA_HEAP_OPTS。

导出KAFKA_HEAP_OPTS="-Xmx1G-Xms1G"

如果在通过脚本启动Kafka之前设置了var，它将使用var而不是< code >/bin/Kafka-server-start . sh 中定义的默认值