马老师计算机组成原理
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);
}}
