KafkaPublisher and KafkaConsumer Error handling

Can someone point me towards documentation for the Axon Kafka module which explains how to deal with the following issues ?

  1. Kafka Publisher can’t connect to a Kafka Broker
  2. Kafka Consumer can’t connect to a Kafka Broker
  3. Kafka Publisher connects, but forwarding an event to the Kafka topic failed
    In all three scenarios, I would like to stop the flow of messages in the system.


the Kafka component is still somewhat under construction. In Axon 3, our repository wasn’t organized to reflect this properly. In the Axon 4 release, we have decided to distinguish between core components (which are in the AxonFramework repository) and extensions, which are in the extensions-… repositories. The Kafka extension for Axon is still at a milestone release.