馬老師計(jì)算機(jī)組成原理
2022-11-18 21:01 作者:bili_1559000721 | 我要投稿
public abstract class RetryExceptionHandler {
?public static final String SOURCE_TOPIC_KEY = "sourceTopic";
?public static final String PRODUCER_KEY = "producer";
?protected String sourceTopic;
?protected KafkaProducer<String, String> producer;
?public void configure(Map<String, ?> config) {
? ?this.sourceTopic = (String) config.get(SOURCE_TOPIC_KEY);
? ?this.producer = (KafkaProducer<String, String>) config.get(PRODUCER_KEY);
?}}
標(biāo)簽：
