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 默认10skafkaProps.put("session.timeout.ms","10000")// heartbeat.interval.ms 默认3skafkaProps.put("heartbeat.interval.ms","3000")