spring-cloud-stream
spring-cloud-stream copied to clipboard
Investigate, fix if necessary and document manual ACK with functional programming style
If it helps, I've experienced issues when using:
- Kafka binder (v3.0.8.RELEASE)
- Functional style
- Event routing (using application properties, filtering by 'type' header)
- Manual ack
I can't set up manual ack whenever the message is routed via event routing (not sure if I'm missing something, but it will always commit the offset no matter what) + the consumer method is always receiving the message as an Object
. Removing functional style and switching back to annotations, everything works, except for batch mode that's not able to deserialize out of the box.