代码之家  ›  专栏  ›  技术社区  ›  Raman

Kafka流:使用配置参数反序列化异常处理程序

  •  0
  • Raman  · 技术社区  · 6 年前

    我不熟悉Java反射。MyCustomException类实现 在streamsConfig中,我了解可以提供类。但是,是否有办法提供 configs (在配置方法中)与类一起?你能提供一个样本代码吗?

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

    .

    public class MyCustomException implements DeserializationExceptionHandler {
    
        @Override
        public void configure(Map<String, ?> configs) {
    
        }
    
    1 回复  |  直到 6 年前
        1
  •  2
  •   Matthias J. Sax    6 年前

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