如何为Kafka设置Java选项?

我一直在试验Kafka,并从主站点的文档中看到,您可以为jvm设置不同的选项,例如堆大小和它使用的垃圾收集器:

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

但是,没有说的是如何/在何处设置这些选项。该应用程序带有一个/ config目录,其中包含许多用于配置目的的文件,但没有用于Java的文件。它还带有一个/

bin目录,其中包含一堆Kafka脚本,但是同样,没有任何东西真正表明如何配置Java。

所以我的问题是,如何配置Kafka使用的Java选项?是通过文件完成还是有其他方法?

回答:

我不同意接受的答案。bin不建议在目录中修改脚本。将Kafka升级到下一版本时,提取新的二进制文件将覆盖脚本中所做的更改。

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

export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"

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

以上是 如何为Kafka设置Java选项? 的全部内容, 来源链接: utcz.com/qa/412811.html

回到顶部