search

micronaut-projects / micronaut-kafka

Integration between Micronaut and Apache Kafka
Apache License 2.0
86 stars 107 forks source link

Suspend @KafkaListener functions #874

Closed hanahavlova closed 1 year ago

hanahavlova commented 1 year ago

Proposal to fix a bug where method.isSuspended() always returns false and thus excludes the possibility of using suspend consumer functions

guillermocalvo commented 1 year ago

I believe some of these fixes should go directly on micronaut-core. It will allow us to remove the temporary workaround.

@sdelamo please take a look at the changes I pushed here and there: https://github.com/micronaut-projects/micronaut-core/pull/9910)

sdelamo commented 1 year ago

@guillermocalvo can you merge master into this? Master contains latest Micronaut core

guillermocalvo commented 1 year ago

can you merge master into this? Master contains latest Micronaut core

@sdelamo I merged master and removed the workaround 👍