The Kafka adapter for Diffusion™ enables sharing messages
between Diffusion and Apache Kafka clusters.
Note: This version of the Kafka adapter is beta software, and should not be used in production.
The Kafka adapter comprises the following files all located in the
directory of your Diffusion
- This JAR file contains the
Java™ application that links the Diffusion server and a Kafka cluster.
- This file is used to configure the Kafka adapter.
- This JSON schema file can be used to validate the application.conf configuration file.
- kafka_adapter.sh and
- These executable files can be used to start the Kafka adapter on UNIX®, Linux™, or Windows™ systems.
The Kafka adapter requires Java. The version requirements are the same as for the Diffusion server.
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.