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.