Axon Kafka Extension - Release 4.5.4

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 StreamableKafkaMessageSource started, it created a new consumer group.
    This implementation will eventually construct many groups within Kafka that are never used, as contributor aupodogov noted 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.
  • Contributor zambrovski noticed that when FetchEventTask dies, 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.