此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 spring-cloud-stream 4.1.4！spring-doc.cadn.net.cn

Tombstone 唱片公司

使用压缩主题时，带有null值（也称为逻辑删除记录）表示删除键。要在 Spring Cloud Stream 函数中接收此类消息，您可以使用以下策略。spring-doc.cadn.net.cn

@Bean
public Function<Message<Person>, String> myFunction() {
    return value -> {
        Object v = value.getPayload();
        String className = v.getClass().getName();
        if (className.isEqualTo("org.springframework.kafka.support.KafkaNull")) {
            // this is a tombstone record
        }
        else {
            // continue with processing
        }
    };
}