kafka-connect-common

Лицензия	Лицензия Apache License 2.0
Категории	Категории Данные
Группа	Группа com.datamountaineer
Идентификатор	Идентификатор kafka-connect-common
Последняя версия	Последняя версия 2.0.5
Дата	Дата 23 окт. 2020 г.
Тип	Тип jar
Описание	Описание kafka-connect-common kafka-connect-common
Ссылка на сайт	Ссылка на сайт https://github.com/lensesio/kafka-connect-common
Система контроля версий	Система контроля версий https://github.com/lensesio/kafka-connect-common.git

Скачать kafka-connect-common

Имя Файла	Размер
kafka-connect-common-2.0.5.pom
kafka-connect-common-2.0.5.jar	15 MB
kafka-connect-common-2.0.5-sources.jar	67 KB
kafka-connect-common-2.0.5-scaladoc.jar	1 MB
kafka-connect-common-2.0.5-javadoc.jar	19 KB
Обзор

Как подключить последнюю версию

Apache Maven

<!-- https://jarcasting.com/artifacts/com.datamountaineer/kafka-connect-common/ -->
<dependency>
    <groupId>com.datamountaineer</groupId>
    <artifactId>kafka-connect-common</artifactId>
    <version>2.0.5</version>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/com.datamountaineer/kafka-connect-common/
implementation 'com.datamountaineer:kafka-connect-common:2.0.5'

Gradle Kotlin

// https://jarcasting.com/artifacts/com.datamountaineer/kafka-connect-common/
implementation ("com.datamountaineer:kafka-connect-common:2.0.5")

Apache Buildr

'com.datamountaineer:kafka-connect-common:jar:2.0.5'

Apache Ivy

<dependency org="com.datamountaineer" name="kafka-connect-common" rev="2.0.5">
  <artifact name="kafka-connect-common" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='com.datamountaineer', module='kafka-connect-common', version='2.0.5')
)

Scala SBT

libraryDependencies += "com.datamountaineer" % "kafka-connect-common" % "2.0.5"

Leiningen

[com.datamountaineer/kafka-connect-common "2.0.5"]

Зависимости

runtime (5)

Идентификатор библиотеки	Тип	Версия
com.sksamuel.avro4s : avro4s-core_2.12	jar	1.6.4
org.json4s : json4s-native_2.12	jar	3.6.7
org.json4s : json4s-jackson_2.12	jar	3.6.7
com.landoop : kafka-connect-smt_2.12	jar	2.0.0
com.datamountaineer : kcql	jar	2.8.7

test (8)

Идентификатор библиотеки	Тип	Версия
org.mockito : mockito-scala_2.12	jar	1.13.0
org.scalacheck : scalacheck_2.12	jar	1.14.3
org.scalatest : scalatest_2.12	jar	3.1.1
junit : junit	jar	4.12
org.apache.curator : curator-test	jar	3.1.0
org.powermock : powermock-module-junit4	jar	1.6.5
org.pegdown : pegdown	jar	1.1.0
com.vladsch.flexmark : flexmark-all	jar	0.35.10

Модули Проекта

Данный проект не имеет модулей.

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.

Lenses.io

The Real Time applications and data operation #DataOps portal for Apache Kafka and Kubernetes

Версии библиотеки

Версия
2.0.5 23 окт. 2020 г.
2.0.4 8 сент. 2020 г.
2.0.3 20 авг. 2020 г.
2.0.2 11 июн. 2020 г.
2.0.1 17 апр. 2020 г.
2.0.0 16 апр. 2020 г.
1.1.9 8 янв. 2020 г.
1.1.8 7 июн. 2019 г.
1.1.7 26 сент. 2018 г.
1.1.6 18 сент. 2018 г.
1.1.5 29 июн. 2018 г.
1.1.4 1 июн. 2018 г.
1.1.3 31 мая 2018 г.
1.1.2 30 мая 2018 г.
1.1.1 29 мая 2018 г.
1.1.0 25 апр. 2018 г.
1.0.9 20 апр. 2018 г.
1.0.8 19 мар. 2018 г.
1.0.7 5 мар. 2018 г.
1.0.6 23 февр. 2018 г.
1.0.5 5 февр. 2018 г.
1.0.4 25 янв. 2018 г.
1.0.3 14 янв. 2018 г.
1.0.2 2 янв. 2018 г.
1.0.1 28 дек. 2017 г.
1.0.0 28 дек. 2017 г.
0.9.7 12 янв. 2018 г.
0.9.6.3 2 янв. 2018 г.
0.9.6.2 2 янв. 2018 г.
0.9.6.1 2 янв. 2018 г.
0.9.6 28 дек. 2017 г.
0.9.5 28 дек. 2017 г.
0.9.3 27 дек. 2017 г.
0.9.2 27 дек. 2017 г.
0.9.1 21 дек. 2017 г.
0.9.0 8 нояб. 2017 г.
0.8.3.3 18 дек. 2017 г.
0.8.3.2 2 нояб. 2017 г.
0.8.3.1 2 нояб. 2017 г.
0.8.3.0 31 окт. 2017 г.
0.8.2.9 5 окт. 2017 г.
0.8.2.7 17 сент. 2017 г.
0.8.2.6 28 авг. 2017 г.
0.8.2.5 24 авг. 2017 г.
0.8.2.4 23 авг. 2017 г.
0.8.2.3 23 авг. 2017 г.
0.8.2.2 16 авг. 2017 г.
0.8.2.1 13 авг. 2017 г.
0.8.1.3 23 авг. 2017 г.
0.8.1.1 11 авг. 2017 г.
0.8.1 7 авг. 2017 г.
0.8.0 7 авг. 2017 г.
0.7.9 3 авг. 2017 г.
0.7.8 20 июн. 2017 г.
0.7.7 30 мая 2017 г.
0.7.6-cp3.1.2 27 апр. 2017 г.
0.7.6 27 апр. 2017 г.
0.7.5-cp3.1.2 26 апр. 2017 г.
0.7.5 26 апр. 2017 г.
0.7.4-cp3.1.2 6 апр. 2017 г.
0.7.4 3 апр. 2017 г.
0.7.3 2 апр. 2017 г.
0.7.2 29 мар. 2017 г.
0.7.1 24 мар. 2017 г.
0.7.0 3 мар. 2017 г.
0.6.9 3 мар. 2017 г.
0.6.8 5 февр. 2017 г.
0.6.7 5 февр. 2017 г.
0.6.6 15 янв. 2017 г.
0.6.5 15 янв. 2017 г.
0.6.4 15 янв. 2017 г.
0.6.3 4 янв. 2017 г.
0.6.2 30 дек. 2016 г.
0.6.1 20 дек. 2016 г.
0.6 16 дек. 2016 г.
0.5 10 окт. 2016 г.
0.4.2 5 окт. 2016 г.
0.4.1 16 сент. 2016 г.
0.4 14 сент. 2016 г.
0.3.8 26 авг. 2016 г.
0.3.7 19 июл. 2016 г.
0.3.5 4 июл. 2016 г.
0.3.4 23 июн. 2016 г.
0.3.3 21 июн. 2016 г.
0.3.1 6 июн. 2016 г.
0.3 5 июн. 2016 г.
0.2.2.1 30 мая 2016 г.
0.2.2 29 мая 2016 г.
0.2.1 7 мая 2016 г.
0.2 4 мая 2016 г.
0.1 27 апр. 2016 г.

kafka-connect-common

Лицензия

Категории

Группа

Идентификатор

Последняя версия

Дата

Тип

Описание

Ссылка на сайт

Система контроля версий

Скачать kafka-connect-common

Как подключить последнюю версию

Зависимости

runtime (5)

test (8)

Модули Проекта

Releases

kafka-connect-common

Packages

Config

SSLConfigConext

Offsets

Queues

Sink

DbWriter

KeyBuilder

Schemas

PayloadFields

ConvertUtil

StructFieldsExtractor

Lenses.io

Версии библиотеки