lensesio / Kafka Connect Common
Licence: apache-2.0
Common components used across the datamountaineer kafka connect connectors
Stars: ✭ 21
Programming Languages
scala
5932 projects
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.
Packages
Config
SSLConfigConext
Contains class for SSL Context configuration for supplied trust and keystores.
Offsets
The offset handler retrieves, from Kafka the stored offset map per source partition.
Queues
Helper methods to drain LinkedBlockingQueues.
Sink
Contains Writer and KeyBuilder classes.
DbWriter
Defines the contract for inserting a new row for the connect sink record.
KeyBuilder
- Builds the new record key for the given connect SinkRecord.
- Builds a new key from the payload fields specified.
Schemas
- RestService to integrate with the Schema Registry
PayloadFields
Works out the fields and their mappings to be used when inserting a new row.
ConvertUtil
Converts source and sink records to JSON and Avro and back.
StructFieldsExtractor
Extracts fields from a SinkRecord Struct based on a specified set of provided columns.
Note that the project description data, including the texts, logos, images, and/or trademarks,
for each open source project belongs to its rightful owner.
If you wish to add or remove any projects, please contact us at [email protected].