Closed rorueda closed 8 months ago
In my use case, it is best to batch process the messages by kafka partition, thus the kafka ConsumerRecords container type is ideal, but currently micronaut doesn't support it and I have a workaround in place to make it work.
ConsumerRecords
I'd like to propose the following change to support ConsumerRecords: https://github.com/micronaut-projects/micronaut-kafka/compare/master...rorueda:micronaut-kafka:consumer-records-support
Please let me know what you guys think.
seems useful. PRs most welcome
Feature description
In my use case, it is best to batch process the messages by kafka partition, thus the kafka
ConsumerRecords
container type is ideal, but currently micronaut doesn't support it and I have a workaround in place to make it work.I'd like to propose the following change to support
ConsumerRecords
: https://github.com/micronaut-projects/micronaut-kafka/compare/master...rorueda:micronaut-kafka:consumer-records-supportPlease let me know what you guys think.