As of Monday the 23th of May, there’s a new patch release of Axon’s Kafka Extension out there.
There are two noteworthy adjustments in there that I’d recommend everybody using the extension to benefit from, by upgrading to 4.5.4:
- 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.
You can find the complete list of changes in release 4.5.4 here.