Kafka Integration

follow these steps to set up the integration with kafka connector before you begin you will need the following access to a kafka broker refer to the following links to learn more apache kafka download the ca certificate and other required authentication parameters needed to access the broker step 1 edit kafka connector to configure kafka integration in litmus uns navigate to integrations from the side menu the integration pane appears to add a new configuration or edit an existing configuration, click edit the edit kafka connector dialog box appears enter the following connection details brokers list add the kafka broker address (e g , 10 17 10 49 9092 ) enable toggle turn the connector on or off sasl mechanism choose the type ( none , sasl plain , scram sha 256 , scram sha 512 ) username and password add these if the broker requires them timeout (seconds) set how long to wait when connecting compression choose a method ( none , gzip , lz4 , snappy , zstd ) required acks pick acknowledgment settings ( none , all , leader ) turn on the require ssl option if needed for secure communication topic mapping click the + icon and add mqtt topics with kafka topics wildcards can be used click save to apply the settings step 2 enable the connector after adding the connector, click the toggle in the connector tile to enable it step 3 verify connection access the kafka broker and verify that litmus uns is successfully sending data