spring cloud stream kafka-功能性方法：在生成墓碑记录时从不调用消费者

Question

问题与https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/455但对于功能性方法

    @Bean
    public Consumer<Message<Foo>> fooConsumer() {
        return message -> {
            String key = // From message header - KafkaHeaders.RECEIVED_MESSAGE_KEY
            Foo payLoad = message.getPayload();

            if (payLoad == null) {
                deleteSomething(key);
            } else {
                addSomething(key, payLoad);
            }
        };
    }

当产生适当的“Foo”（json）时，会调用fo消费者。但是当产生“null”有效负载/墓碑时，永远不会调用消费者函数。

我尝试使用自定义“Convertor”方法的变通方法，该方法正在发挥作用：

@Component
public class KafkaNullConverter extends MappingJackson2MessageConverter {

    @Override
    protected Object convertFromInternal(Message<?> message, @NonNull Class<?> targetClass, Object conversionHint) {
        if (message.getPayload() instanceof KafkaNull) {
            return Foo.builder().isDeleted(true).build(); // Note: new `isDeleted` field added to `Foo`
        }

        return super.convertFromInternal(message, targetClass, conversionHint);
    }
}

然后，食品消费者可以检查有效载荷。isDeleted（）来处理大小写。但这是冗长的，会污染pojo/模型类，并且必须对每个消费者重复。

我理解spring集成不能使用null。但是，有没有更好的/标准的方法来用功能方法处理“墓碑”用例？

版本：3.0.4。发布

<dependency>
   <groupId>org.springframework.cloud</groupId>
   <artifactId>spring-cloud-stream-binder-kafka</artifactId>
   <version>3.0.4.RELEASE</version>
</dependency>

Answer 1

这是最近固定的主要分支https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/pull/936和https://github.com/spring-cloud/spring-cloud-function/issues/557