Axon 4.0 kafka-extension eventhandling

Imported from Google Groups
1

Hi,

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

axon.eventhandling.processors.Accounts.source=kafkaMessageSource
axon.eventhandling.processors.Accounts.mode=TRACKING



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



if I use streamableKafkaMessageSource I get bean not found error.



thanks.
2

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,