Axon 4.0 kafka-extension eventhandling


Can anybody please suggest how to write following config using Axon 4 kafka extension:


this config works using Axon 3.3 but not when using kafka extension.

if I use streamableKafkaMessageSource I get bean not found error.


Hi Gurdial,

the “Accounts” part is the name of the processor. This is either the processor you have configured for your classes, or there should be an @ProcessingGroup(“Accounts”) on this handler.
Secondly, you should have the KafkaMessageSource configured with “kafkaMessageSource” (in your case) as bean name.

Kind regards,