Axon with Kafka

[Mayuresh]

Dear All, 

I have some hands on with Axon , MongoDB and RabbitMQ. But I am looking for examples which have integration with Kafka, and not RabbitMQ. Can anyone help me with this? Any help will be much appreciated.

Regards,

Mayuresh

[Simon Zambrovski]

Hi,

I'm planing to implement Kafka eventstore. Kafka messaging is pretty straight forward, but Kafka 0.10 is not supporting Record Headers, so the message converter looks little wierd.

Kind regards,

Simon

[malay.m...@peaas.co]

Hi Mayuresh,

I need to do the same, did you find any example or were you able to achieve it? If so then could you guide me how to integrate Kafka instead of RabbitMQ?

Thanks,

Malay

[Marinko Babic]

https://github.com/marinkobabic/axon-kafka-example

--
You received this message because you are subscribed to the Google Groups "Axon Framework Users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to axonframewor...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[Malay Matwankar]

Hi Marniko,

This example does not show how the  Sender.java  binds EventHandler with the Kafka. Could you explain that bit?

Regards,

Malay

Thanks and Regards,

Malay Matwankar

Software Engineer

PEaaS Software LLP | 112, Shreeji Complex, Vasna Road, Vadodara, Gujarat |

Mobile No: +91 9408728919

Skype      :  malaymatwankar

E-mail     :  malay.m...@peaas.co

Website   :  http://peaas.co

https://github.com/marinkobabic/axon-kafka-example

To unsubscribe from this group and stop receiving emails from it, send an email to axonframework+unsubscribe@googlegroups.com.

For more options, visit https://groups.google.com/d/optout.

--

You received this message because you are subscribed to the Google Groups "Axon Framework Users" group.

To unsubscribe from this group and stop receiving emails from it, send an email to axonframework+unsubscribe@googlegroups.com.

[Marinko Babic]

Hi Malay

Sender is just the producer of an event. It publishes an event. The consumer application is the part where the EventHandler is used. Like you can see in the configuration there is a Trackingprocessor defined with Kafka as event source. The EventHandler will be invoked automatically by axon, because of:

- the topic

- Kafka event source 

- processinggroup 

In my example the processinggroup matches the java package name. If this is not the case, then the annotation processinggroup is needed on the EventHandler and it must match the name defined as key of the processor in the configuration.

Actually Axon only supports trackingprocessor for Kafka which is absolutely fine.

https://github.com/marinkobabic/axon-kafka-example

To unsubscribe from this group and stop receiving emails from it, send an email to axonframewor...@googlegroups.com.

For more options, visit https://groups.google.com/d/optout.

--
You received this message because you are subscribed to the Google Groups "Axon Framework Users" group.

To unsubscribe from this group and stop receiving emails from it, send an email to axonframewor...@googlegroups.com.

For more options, visit https://groups.google.com/d/optout.

--
You received this message because you are subscribed to the Google Groups "Axon Framework Users" group.

To unsubscribe from this group and stop receiving emails from it, send an email to axonframewor...@googlegroups.com.