Configuring Confluent Distribution of Kafka
Adapter for Apache Kafka supports the Confluent platform for Apache Kafka. For Avro Serialization and Schema Registry configuration changes that are applicable if you are using a non-confluent connection type, you must perform the following:
1. Copy the required libraries to the Integration Server_directory\instances\instance_name\packages\code\jars directory. The list of libraries to copy are as follows:
![*](chapterTOC_bullet.png)
avro-1.10.1.jar
![*](chapterTOC_bullet.png)
common-config-6.2.0.jar
![*](chapterTOC_bullet.png)
common-utils-6.2.0.jar
![*](chapterTOC_bullet.png)
jakarta.ws.rs-api-2.1.6.jar
![*](chapterTOC_bullet.png)
jersey-client-2.30.jar
![*](chapterTOC_bullet.png)
jersey-common-2.30.jar
![*](chapterTOC_bullet.png)
kafka_2.13-6.2.0-ccs.jar
![*](chapterTOC_bullet.png)
kafka-avro-serializer-6.2.0.jar
![*](chapterTOC_bullet.png)
kafka-clients-6.2.0-ccs.jar
![*](chapterTOC_bullet.png)
kafka-schema-registry-client-6.2.0.jar
![*](chapterTOC_bullet.png)
kafka-schema-serializer-6.2.0.jar
![*](chapterTOC_bullet.png)
kafka-tools-6.2.0-ccs.jar
![*](chapterTOC_bullet.png)
wm-kafka-v9.jar
![*](chapterTOC_bullet.png)
zookeeper-3.5.9.jar
Note:
You can use the JAR files with versions specified or higher.
2. Set the following fields for Adapter for Apache Kafka Producer Connection and SASL Producer Connection type.
![*](chapterTOC_bullet.png)
Set the
Other Properties to
schema.registry.url=http://host:port. For example:
schema.registry.url=http://vmkavp02:8091
![*](chapterTOC_bullet.png)
Set the
Value Serializer Class to
io.confluent.kafka.serializers.KafkaAvroSerializer.
3. Set the following fields for Adapter for Apache Kafka Consumer Connection and SASL Consumer Connection type.
![*](chapterTOC_bullet.png)
Set the
Other Properties to
schema.registry.url=http://host:port;specific.avro.reader=true. For example:
schema.registry.url=http://vmkavp02:8091;specific.avro.reader=true
![*](chapterTOC_bullet.png)
Set the
Value Deserializer Class to
io.confluent.kafka.serializers.KafkaAvroDeserializer.