当前位置: 首页 > 面试题库 >

如何为Kafka设置Java选项?

田硕
2023-03-14
问题内容

我一直在试验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,并从主站点的文档中看到,您可以为jvm设置不同的选项,例如堆大小和它使用的垃圾收集器: http://kafka.apache.org/documentation.html#java 但是,没有说的是如何/在何处设置这些选项。该应用程序带有一个/ config目录,其中包含许多用于配置目的的文件,但没有用于Java的文件。它还带有一个/ bin目录,其中包含一堆

  • 我有两个关于Intellij IDEA中Gradle的问题 我知道退出按钮将优雅地关闭java应用程序 (文件)- 但我想知道如何通过gradle run优雅地关闭我的java应用程序? 因为gradle运行时没有退出按钮 (文件)- 另一个问题是如何通过编辑配置将java选项(如-Xmx选项)设置为java应用程序 虚拟机选项似乎设置了gradle虚拟机选项,而不是我的java应用程序选项。 非

  • 我是Kafka Streams的新手,我正在使用1.0.0版。我想从其中一个值为KTable设置一个新密钥。 在使用KStream时,可以使用如下方法selectKey()完成。 然而,KTable中缺少这种方法。唯一的方法是将给定的KTable转换为KStream。对这个问题有什么想法吗?它改变了KTable设计的关键?

  • Highcharts 是通过 JavaScript 对象的形式(JSON)来定义图表的配置参数。 一、图表配置对象 当使用图表构造函数 Highcharts.Chart 来初始化图表时,图表的配置对象是以第二个参数传递给该构造函数的。 下面是示例代码(其中红色部分是配置对象): var options = { chart: { type: 'bar' },

  • 问题内容: 我可以如下设置Firefox的代理设置。 但是我也需要设置Chrome。.有人可以帮助我怎么做吗? 谢谢拉吉 问题答案: 您可以尝试使用该类,如下所示:

  • 我是Android编程的新手,首先我想用SharedPreays做一个简单的选项菜单演示。我已经创建了基本的结构,但是我不知道如何将OnPreancceClickListener附加到Preation。尽管如此,我可以使用onSharedPreancceChanged方法,但是没有其他事件侦听器。(再次,我是初学者,所以我不知道为什么会这样。) 我已经阅读了有关创建菜单步骤的文档:https://