Kafka Connect Common is in Maven, include it in your connector.

Releases

Version	Confluent Version	Kafka	Kcql Version	Scala Version
2.0.5	5.4.0	2.4.0	2.8.7	2.12
2.0.4	5.4.0	2.4.0	2.8.7	2.12
2.0.3	5.4.0	2.4.0	2.8.6	2.12
2.0.2	5.4.0	2.4.0	2.8.5	2.12
2.0.1	5.4.0	2.4.0	2.8.4	2.12
2.0.0	5.4.0	2.4.0	2.8.4	2.12
1.1.9	5.0.0	1.1.0	2.8.4	2.11
1.1.8	5.0.0	1.1.0	2.8.4	2.11
1.1.5	5.0.0	1.1.0	2.8.2	2.11
1.1.5	4.1.0	1.1.0	2.8.2	2.11
1.1.4	4.1.0	1.1.0	2.8.2	2.11
1.1.3	4.1.0	1.1.0	2.8	2.11
1.1.2	4.1.0	1.1.0	2.7	2.11
1.1.1	4.1.0	1.1.0	2.5.1	2.11
1.1.0	4.1.0	1.1.0	2.5.1	2.11
1.0.9	4.0.0	1.0.0	2.5.1	2.11
1.0.8	4.0.0	1.0.0	2.5.1	2.11
1.0.7	4.0.0	1.0.0	2.5.1	2.11
1.0.6	4.0.0	1.0.0	2.5.1	2.11
1.0.5	4.0.0	1.0.0	2.5.1	2.11
1.0.4	4.0.0	1.0.0	2.5.1	2.11
1.0.3	4.0.0	1.0.0	2.4	2.11
1.0.2	4.0.0	1.0.0	2.4	2.11
1.0.1	4.0.0	1.0.0	2.4	2.11
1.0.2	4.0.0	1.0.0	2.4	2.11
1.0.1	4.0.0	1.0.0	2.4	2.11
1.0.0	4.0.0	1.0.0	2.4	2.11

#maven
<dependency>
	<groupId>com.datamountaineer</groupId>
	<artifactId>kafka-connect-common</artifactId>
	<version>LATEST</version>
</dependency>

kafka-connect-common

Common components used across the datamountaineer kafka connect connectors.

Contains class for SSL Context configuration for supplied trust and keystores.

The offset handler retrieves, from Kafka the stored offset map per source partition.

Helper methods to drain LinkedBlockingQueues.

Contains Writer and KeyBuilder classes.

Defines the contract for inserting a new row for the connect sink record.

Works out the fields and their mappings to be used when inserting a new row.

Converts source and sink records to JSON and Avro and back.

Extracts fields from a SinkRecord Struct based on a specified set of provided columns.