【问题标题】:Adding a Kafka service failes添加 Kafka 服务失败
【发布时间】:2018-05-21 07:39:20
【问题描述】:

我们有 Cloudera Express 5.11.0 集群,我正在尝试将 Kafka 3.0 作为服务添加到 cloudera 管理器中,但我收到错误消息,它无法在所有节点上启动代理,但我没有看到任何错误。我下载了percel并分发激活成功。

我有几个问题:

  1. 我应该在 ZooKeeper Root 中设置什么值?这是我应该决定的还是取决于动物园管理员的安装?我看到最常见的是/kafka,所以我把它设置为/kafka。

  2. 我们的 zookeeper 作为独立运行并收到有关最大请求延迟的警报,可能已连接?

  3. 在将 Kafka 添加为服务的第 4 步中,在节点中启动代理失败,我不确定是什么错误。我看到了一些关于 OutOfMemory 的消息,但我不确定它是检查还是错误。

我将添加我找到的日志的最后几行:

标准输出:

 AUTHENTICATE_ZOOKEEPER_CONNECTION: true
 SUPER_USERS: kafka
 Kafka version found: 0.11.0-kafka3.0.0
 Sentry version found: 1.5.1-cdh5.11.0
 ZK_PRINCIPAL_NAME: zookeeper
 Final Zookeeper Quorum is VMClouderaMasterDev01:2181/kafka
 security.inter.broker.protocol inferred as PLAINTEXT
 LISTENERS=listeners=PLAINTEXT://VMClouderaWorkerDev03:9092,
 java.lang.OutOfMemoryError: Java heap space
 Dumping heap to /tmp/kafka_kafka-KAFKA_BROKER-     933a1dc0c29ca08ffe475da27d5b13d4_pid113208.hprof ...
 Heap dump file created [12122526 bytes in 0.086 secs]
 #
 # java.lang.OutOfMemoryError: Java heap space
 # -XX:OnOutOfMemoryError="/usr/lib64/cmf/service/common/killparent.sh"
 #   Executing /bin/sh -c "/usr/lib64/cmf/service/common/killparent.sh"...

标准错误:

+ export 'KAFKA_JVM_PERFORMANCE_OPTS=-XX:+HeapDumpOnOutOfMemoryError -                
XX:HeapDumpPath=/tmp/kafka_kafka-KAFKA_BROKER-    
933a1dc0c29ca08ffe475da27d5b13d4_pid113208.hprof - 
XX:OnOutOfMemoryError=/usr/lib64/cmf/service/common/killparent.sh -server - 
XX:+UseParNewGC -XX:+UseConcMarkSweepGC -XX:+CMSClassUnloadingEnabled - 
XX:+CMSScavengeBeforeRemark -XX:+DisableExplicitGC -Djava.awt.headless=true'
+ KAFKA_JVM_PERFORMANCE_OPTS='-XX:+HeapDumpOnOutOfMemoryError - 
XX:HeapDumpPath=/tmp/kafka_kafka-KAFKA_BROKER- 
933a1dc0c29ca08ffe475da27d5b13d4_pid113208.hprof - 
XX:OnOutOfMemoryError=/usr/lib64/cmf/service/common/killparent.sh -server - 
XX:+UseParNewGC -XX:+UseConcMarkSweepGC -XX:+CMSClassUnloadingEnabled - 
XX:+CMSScavengeBeforeRemark -XX:+DisableExplicitGC -Djava.awt.headless=true'
+ [[ false == \t\r\u\e ]]
+ exec /opt/cloudera/parcels/KAFKA-3.0.0-1.3.0.0.p0.40/lib/kafka/bin/kafka- 
server-start.sh /var/run/cloudera-scm-agent/process/1177-kafka- 
KAFKA_BROKER/kafka.properties
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/opt/cloudera/parcels/KAFKA-3.0.0- 
1.3.0.0.p0.40/lib/kafka/libs/slf4j-log4j12- 
1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/opt/cloudera/parcels/KAFKA-3.0.0- 
1.3.0.0.p0.40/lib/kafka/libs/slf4j-log4j12- 
1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an 
explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
+ grep -q OnOutOfMemoryError /proc/113208/cmdline
+ RET=0
+ '[' 0 -eq 0 ']'
+ TARGET=113208
++ date
+ echo Thu May 17 10:36:08 CDT 2018
+ kill -9 113208

/var/log/kafka/*.log :

50.1.22:2181, initiating session
2018-05-17 10:36:08,028 INFO org.apache.zookeeper.ClientCnxn: Session     establishment complete on server VMClouderaMasterDev01/10.150.1.22:2181,     sessionid = 0x1626c7087e729cb, negotiated timeout = 6000
2018-05-17 10:36:08,028 INFO org.I0Itec.zkclient.ZkClient: zookeeper state     changed (SyncConnected)
2018-05-17 10:36:08,183 INFO kafka.server.KafkaServer: Cluster ID =     cM_4kCm6TZWxttCAXDo4GQ
2018-05-17 10:36:08,185 WARN kafka.server.BrokerMetadataCheckpoint: No     meta.properties file under dir /var/local/kafka/data/meta.properties
2018-05-17 10:36:08,222 INFO     kafka.server.ClientQuotaManager$ThrottledRequestReaper: [ThrottledRequestReaper-    Fetch]: Starting
2018-05-17 10:36:08,224 INFO     kafka.server.ClientQuotaManager$ThrottledRequestReaper: [ThrottledRequestReaper-    Produce]: Starting
2018-05-17 10:36:08,226 INFO kafka.server.ClientQuotaManager$ThrottledRequestReaper: [ThrottledRequestReaper-Request]: Starting
2018-05-17 10:36:08,279 INFO kafka.log.LogManager: Loading logs.
2018-05-17 10:36:08,287 INFO kafka.log.LogManager: Logs loading complete in 8 ms.

【问题讨论】:

    标签: apache-kafka cloudera


    【解决方案1】:

    在我的情况下,解决方案是将 java_heap_broker 大小增加到 1G

    【讨论】:

      猜你喜欢
      • 2020-05-23
      • 2011-11-16
      • 1970-01-01
      • 1970-01-01
      • 2018-02-02
      • 2020-01-19
      • 2021-12-20
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多