I’m using Spring’s `spring-cloud-stream-binder-kafka in my Spring Boot application, featuring a Spring Cloud function responsible for upsert operations. Upon successful execution, this function forwards the input message as output. The configuration for this function is outlined below: