Installing Kafka Connector

In this topic, you can find information about installing the Kafka connector.

Procedure

1. To install the Kafka connector, run the following command:
   /opt/APG/bin/manage-modules.sh install kafka-connector <instance>

   Note: If you leave the instance name blank, the Default instance is created.
2. To configure the connector, run the following command:
   vi /opt/APG/Collecting/Kafka-Connector/Default/conf/kafka-connector.xml

   Output:

   <?xml version="1.0"?>
   <kafka-connector-config xmlns="http://www.watch4net.com/KafkaConnector" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.watch4net.com/KafkaConnector ../kafka-connector.xsd ">
     <kafka-producer-settings>
       <!-- Servers information -->
       <server host="10.x.x.x"/>
       <!-- Producer (and topic) information -->
       <producer
         topic-name="rawvalues"
         acks="1" retries="0"
         linger-ms="0ms"
         buffer-memory="33554432"
         compression-type="lz4"
         batch-size="16384"
         max-block-ms="2s"
         max-in-flight-requests-per-connection="5"
         max-request-size="1048576"/>
       <!-- All connection parameters will be attributes except "server" -->
       <connection request-timeout-ms="5s" connections-max-idle-ms="9m" retry-backoff-ms="100ms" reconnect-backoff-ms="50ms"/>
       <!-- Additional properties -->
       <additional-parameters key="metadata.max.age.ms">1000</additional-parameters>
       <additional-parameters key="receive.buffer.bytes">32768</additional-parameters>
       <additional-parameters key="send.buffer.bytes">131072</additional-parameters>
     </kafka-producer-settings>
     <connector-component-behavior flush-every-n-values="5000"/>
   </kafka-connector-config>
   

   Note: Where, <server host> must point to the IP address of the VMware Telco Cloud Service Assurance domainmanager worker. And the topic name must be called as rawvalues.