Any patch release made for an Axon project aims to resolve bugs. This page provides an overview of patch releases for the Axon Kafka Extension.
- Whenever the
StreamableKafkaMessageSourcestarted, it created a new consumer group. This implementation will eventually construct many groups within Kafka that are never used, as contributor
aupodogovnoted in this issue. We solved this issue by manually validating all the partitions instead of constructing a new consumer group each time. For those interested, the pull request for this can be found here.
zambrovskinoticed that when
FetchEventTaskdies, it did not put the Event Processor in error mode even though it should. To solve this, we ensured the error was rethrown far enough for the Event Processor to react to it accordingly. If you're curious about the solution, you can find the changes in pull request #287.