我不熟悉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) {
}
1条答案
按热度按时间gcuhipw91#
那辆车过去了
Map<String, ?> configs
参数应包含添加到Properties
你进入KafkaStreams
建造师。因此,您只需在那里添加所需的配置,它就会相应地被转发。