flink k8s sink到kafka报错 Failed to get metadata for topics

• 大数据

可能出现的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://www.net2asp.com/69d7b288e7.html

赞 (0)
« 上一篇 1天前
下一篇 » 1天前

相关推荐