Expand Collapse
Just a second...

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:
  1. Use the application.conf configuration file to define the Kafka adapter behavior.

    For more information, see Configuring the Kafka Adapter.

  2. 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:

  1. 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
  2. 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>
  3. Update the URL of the Diffusion server in application.conf to use "wss://"