Kafka adapter
The Kafka adapter for Diffusion™ enables sharing messages between Diffusion and Apache Kafka clusters.
Kafka adapter
- kafka-adapter-6.7.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.