kafka流:带配置参数的反序列化ExceptionHandler

jjhzyzn0  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(295)

我不熟悉java反射。mycustomexception类实现反序列化ExceptionHandler接口,在streamsconfig中,我知道可以提供该类。但是,有没有办法将configs(在configure方法中)与类一起提供?你能提供一个样本代码吗?

streamsConfig.put(StreamsConfig.DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG, MyCustomException.class);

.

public class MyCustomException implements DeserializationExceptionHandler {

    @Override
    public void configure(Map<String, ?> configs) {

    }
gcuhipw9

gcuhipw91#

那辆车过去了 Map<String, ?> configs 参数应包含添加到 Properties 你进入 KafkaStreams 建造师。因此,您只需在那里添加所需的配置,它就会相应地被转发。

相关问题