可能出现的3种报错
-- 报错1
Failed to get metadata for topics [...].
org.apache.kafka.common.errors.TimeoutException: Call
-- 报错2
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting to send the call. Call: fetchMetadata
Heartbeat must be set lower than the session timeout
-- 报错3
Timed out waiting for a node assignment. Call: describeTopics
--
-- 解决方法: consumer的配置中 添加下面参数解决: com.tuya.flink.EnergyMeteringMontior.Drive#buildKafkaProducer
// session.timeout.ms 默认10s
kafkaProps.put("session.timeout.ms","10000")
// heartbeat.interval.ms 默认3s
kafkaProps.put("heartbeat.interval.ms","3000")
本文转载自: https://blog.csdn.net/qq_35515661/article/details/132667372
版权归原作者 Thomas2143 所有, 如有侵权,请联系我们删除。
版权归原作者 Thomas2143 所有, 如有侵权,请联系我们删除。