Running the Kafka adapter
The Kafka adapter is not enabled by default.
The Kafka adapter is a Java™ application. The adapter has the same version requirements as the Diffusion™ server.
To run the Kafka adapter, complete the following steps:
- Use the application.conf configuration file to define the
Kafka adapter behavior.
For more information, see Configuring the Kafka Adapter.
- Run the kafka_adapter.sh or
kafka_adapter.bat script to start the Kafka adapter:
./kafka_adapter.sh
To set up a secure connection with Diffusion:
- Import the Certificate Authority certificate which is used to sign the server's certificate to the local truststore: keytool -keystore local.client.truststore.jks -alias <alias> -import -file <ca-cert file name> -storepass <password> -keypass <password> -noprompt
- Add the following system properties as parameters to the java command in your .sh or .bat start script: -Djavax.net.ssl.trustStore=./local.client.trustStore.jks -Djavax.net.ssl.trustStorePassword=<password>
- Update the URL of the Diffusion server in application.conf to use "wss://"