Just a second...

Kafka adapter

The Kafka adapter for Diffusion™ enables sharing messages between Diffusion and Apache Kafka clusters.

Kafka adapter

The Kafka adapter comprises the following files all located in the adapters/kafka directory of your Diffusion installation:
kafka-adapter-6.6.11.jar
This JAR file contains the Java™ application that links the Diffusion server and a Kafka cluster.
application.conf
This file is used to configure the Kafka adapter.
configSchema.json
This JSON schema file can be used to validate the application.conf configuration file.
kafka_adapter.sh and kafka_adapter.bat
These executable files can be used to start the Kafka adapter on UNIX®, Linux™, or Windows™ systems.
log4j2.xml

The Kafka adapter requires Java. The version requirements are the same as for the Diffusion server.

Using the Kafka adapter

To use the Kafka adapter, first configure it by editing the application.conf to define the adapter behavior. For more information, see Configuring the Kafka adapter.

To run the adapter, use the .sh or .bat file. See Running the Kafka adapter.

Monitoring the Kafka adapter

The adapter uses Prometheus to expose its metrics. This can be accessed using the http://localhost:8000/metrics endpoint. The default '8000' port can be changed in the configuration file.

The adapter can also be visualised and monitored in the Diffusion management console, using the Network tab.