kafka日志出现报错

卡卡*苏米尔 发表于: 2020-07-23   最后更新时间: 2020-07-23 18:53:03   2,693 游览

kafka日志报错;

[2020-07-23 14:12:11,258] ERROR [KafkaApi-1] Error when handling request {acks=1,timeout=30000,
partitionSizes=[ETE_QH_PAASCONF_8630000-0=285]} (kafka.server.KafkaApis)
java.lang.IllegalArgumentException: A metric named 'MetricName [name=throttle-time, group=Produce, 
description=Tracking average throttle-time per user/client-id, tags={client-id=udal|135.202.135.7:10016, user=}]
' already exists, can't register another one.
    at org.apache.kafka.common.metrics.Metrics.registerMetric(Metrics.java:433)
    at org.apache.kafka.common.metrics.Sensor.add(Sensor.java:249)
    at org.apache.kafka.common.metrics.Sensor.add(Sensor.java:234)
    at kafka.server.SensorAccess.getOrCreate(SensorAccess.scala:68)
    at kafka.server.ClientQuotaManager.getOrCreateQuotaSensors(ClientQuotaManager.scala:360)
    at kafka.server.ClientQuotaManager.recordAndMaybeThrottle(ClientQuotaManager.scala:179)
    at kafka.server.KafkaApis.kafka$server$KafkaApis$$sendResponseCallback$2(KafkaApis.scala:415)
    at kafka.server.KafkaApis$$anonfun$handleProducerRequest$1.apply(KafkaApis.scala:433)
    at kafka.server.KafkaApis$$anonfun$handleProducerRequest$1.apply(KafkaApis.scala:433)
    at kafka.server.ReplicaManager.appendRecords(ReplicaManager.scala:338)
    at kafka.server.KafkaApis.handleProducerRequest(KafkaApis.scala:428)
    at kafka.server.KafkaApis.handle(KafkaApis.scala:80)
    at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:62)
    at java.lang.Thread.run(Thread.java:745)
发表于 2020-07-23
添加评论

已经存在了。

你的答案

查看kafka相关的其他问题或提一个您自己的问题