apache-kafka - Kafka Streams：带配置参数的 DeserializationExceptionHandler

Question

我不熟悉Java反射。MyCustomException 类实现了 DeserializationExceptionHandler 接口，并且在 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) {

    }

标签： apache-kafkaapache-kafka-streams

Answer 1

传入的Map<String, ?> configs参数应包含您添加到Properties您传递给KafkaStreams构造函数的所有配置。因此，您可以在此处添加所需的配置，并将相应地转发。