如何为Kafka设置Java选项？

如何为Kafka设置Java选项？

我不同意接受的答案。

bin

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

首选方法应该是

KAFKA_HEAP_OPTS

在脚本外部设置环境变量。

export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"

如果在通过脚本启动Kafka之前设置了var，它将使用var而不是在中定义的默认值

/bin/kafka-server-start.sh