question Re: How do you change Kafka heap memory with CDH (properly) ? in Archives of Support Questions (Read Only) https://community.cloudera.com/t5/Archives-of-Support-Questions/How-do-you-change-Kafka-heap-memory-with-CDH-properly/m-p/29576#M6582 Edit the "Kafka Broker Environment Advanced Configuration Snippet (Safety Valve)" field under CM -&gt; Kafka -&gt; Configuration with the below entry (For a 5g example):<BR /><BR />KAFKA_HEAP_OPTS="-Xmx5g -Xms5g"<BR /><BR />Save and restart. Wed, 15 Jul 2015 08:16:03 GMT Harsh J 2015-07-15T08:16:03Z How do you change Kafka heap memory with CDH (properly) ? https://community.cloudera.com/t5/Archives-of-Support-Questions/How-do-you-change-Kafka-heap-memory-with-CDH-properly/m-p/29574#M6581 <P>&nbsp;</P><P>ps aux | grep -i kafka<BR />kafka 3376 12.3 19.4 5444664 1184292 ? Sl Jun17 4843:42 /usr/lib/jvm/java-7-oracle-cloudera/bin/java <STRONG>-Xmx1G -Xms1G</STRONG> -server -XX:+UseParNewGC -XX:+UseConcMarkSweepGC -XX:+CMSClassUnloadingEnabled -XX:+CMSScavengeBeforeRemark -XX:+DisableExplicitGC -Djava.awt.headless=true -Xloggc:/run/cloudera-scm-agent/process/2769-kafka-KAFKA_BROKER/kafkaServer-gc.log -verbose:gc -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+PrintGCTimeStamps -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.port=9393 -Dkafka.logs.dir=/run/cloudera-scm-agent/process/2769-kafka-KAFKA_BROKER -Dlog4j.configuration=file:/run/cloudera-scm-agent/process/2769-kafka-KAFKA_BROKER/log4j.properties -cp :/opt/cloudera/parcels/KAFKA-0.8.2.0-1.kafka1.3.0.p0.29/lib/kafka/bin/../core/build/dependant-libs-2.10.4*/*.jar:/opt/cloudera/parcels/KAFKA-0.8.2.0-1.kafka1.3.0.p0.29/lib/kafka/bin/../examples/build/libs//kafka-examples*.jar:/opt/cloudera/parcels/KAFKA-0.8.2.0-1.kafka1.3.0.p0.29/lib/kafka/bin/../contrib/hadoop-consumer/build/libs//kafka-hadoop-consumer*.jar:/opt/cloudera/parcels/KAFKA-0.8.2.0-1.kafka1.3.0.p0.29/lib/kafka/bin/../contrib/hadoop-producer/build/libs//kafka-hadoop-producer*.jar:/......etc</P><P>&nbsp;</P><P>how do change that java heap memory for kafka in the proper way with CDH? (because i didn't see it on the cdh config)&nbsp;(CDH 5.4.x)</P><P>&nbsp;</P> Fri, 16 Sep 2022 09:34:08 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/How-do-you-change-Kafka-heap-memory-with-CDH-properly/m-p/29574#M6581 sphinxid 2022-09-16T09:34:08Z Re: How do you change Kafka heap memory with CDH (properly) ? https://community.cloudera.com/t5/Archives-of-Support-Questions/How-do-you-change-Kafka-heap-memory-with-CDH-properly/m-p/29576#M6582 Edit the "Kafka Broker Environment Advanced Configuration Snippet (Safety Valve)" field under CM -&gt; Kafka -&gt; Configuration with the below entry (For a 5g example):<BR /><BR />KAFKA_HEAP_OPTS="-Xmx5g -Xms5g"<BR /><BR />Save and restart. Wed, 15 Jul 2015 08:16:03 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/How-do-you-change-Kafka-heap-memory-with-CDH-properly/m-p/29576#M6582 Harsh J 2015-07-15T08:16:03Z Re: How do you change Kafka heap memory with CDH (properly) https://community.cloudera.com/t5/Archives-of-Support-Questions/How-do-you-change-Kafka-heap-memory-with-CDH-properly/m-p/29944#M6583 A direct property to change this is now available in the most recent CM<BR />5.4.x releases. Once you upgrade, please remember to remove the env-var<BR />workaround so things continue to be configured consistently. Wed, 22 Jul 2015 16:32:02 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/How-do-you-change-Kafka-heap-memory-with-CDH-properly/m-p/29944#M6583 Harsh J 2015-07-22T16:32:02Z