kafka-connect-common-1.0.8-sources.jar

<dependency>
	<groupId>com.datamountaineer</groupId>
	<artifactId>kafka-connect-common</artifactId>
	<version>1.0.8</version>
	<classifier>sources</classifier>
	<type>java-source</type>
</dependency>

com.datamountaineer:kafka-connect-common:1.0.8

META-INF/MANIFEST.MF
com/datamountaineer/streamreactor/connect/json/SimpleJsonConverter.java
com/datamountaineer/streamreactor/connect/offsets/OffsetHandler.scala
com/datamountaineer/streamreactor/connect/rowkeys/RowKeyBuilderString.scala
com/datamountaineer/streamreactor/connect/rowkeys/RowKeyModeEnums.scala
com/datamountaineer/streamreactor/connect/queues/QueueHelpers.scala
com/datamountaineer/streamreactor/connect/converters/FieldConverter.scala
com/datamountaineer/streamreactor/connect/converters/Transform.scala
com/datamountaineer/streamreactor/connect/converters/source/KeyExtractor.scala
com/datamountaineer/streamreactor/connect/converters/source/JsonConverterWithSchemaEvolution.scala
com/datamountaineer/streamreactor/connect/converters/source/MsgKey.scala
com/datamountaineer/streamreactor/connect/converters/source/AvroConverter.scala
com/datamountaineer/streamreactor/connect/converters/source/JsonResilientConverter.scala
com/datamountaineer/streamreactor/connect/converters/source/Converter.scala
com/datamountaineer/streamreactor/connect/converters/source/BytesConverter.scala
com/datamountaineer/streamreactor/connect/converters/source/JsonPassThroughConverter.scala
com/datamountaineer/streamreactor/connect/converters/source/JsonSimpleConverter.scala
com/datamountaineer/streamreactor/connect/converters/sink/SinkRecordToJson.scala
com/datamountaineer/streamreactor/connect/serialization/AvroSerializer.scala
com/datamountaineer/streamreactor/connect/utils/JarManifest.scala
com/datamountaineer/streamreactor/connect/utils/ProgressCounter.scala
com/datamountaineer/streamreactor/connect/concurrent/FutureAwaitWithFailFastFn.scala
com/datamountaineer/streamreactor/connect/concurrent/ExecutorExtension.scala
com/datamountaineer/streamreactor/connect/schemas/StructFieldExtractor.scala
com/datamountaineer/streamreactor/connect/schemas/ConverterUtil.scala
com/datamountaineer/streamreactor/connect/schemas/PayloadFields.scala
com/datamountaineer/streamreactor/connect/schemas/SchemaRegistry.scala
com/datamountaineer/streamreactor/connect/source/ExponentialBackOff.scala
com/datamountaineer/streamreactor/connect/source/ExponentialBackOffHandler.scala
com/datamountaineer/streamreactor/connect/sink/DbWriter.scala
com/datamountaineer/streamreactor/connect/errors/ErrorHandler.scala
com/datamountaineer/streamreactor/connect/errors/ErrorPolicy.scala
com/datamountaineer/streamreactor/connect/config/Helpers.scala
com/datamountaineer/streamreactor/connect/config/SSLConfigContext.scala
com/datamountaineer/streamreactor/connect/config/Routes.scala
com/datamountaineer/streamreactor/connect/config/base/traits/AllowParallelizationSettings.scala
com/datamountaineer/streamreactor/connect/config/base/traits/KcqlSettings.scala
com/datamountaineer/streamreactor/connect/config/base/traits/ErrorPolicySettings.scala
com/datamountaineer/streamreactor/connect/config/base/traits/RetryIntervalSettings.scala
com/datamountaineer/streamreactor/connect/config/base/traits/ConsistencyLevelSettings.scala
com/datamountaineer/streamreactor/connect/config/base/traits/BaseConfig.scala
com/datamountaineer/streamreactor/connect/config/base/traits/NumberRetriesSettings.scala
#内容未全部加载，请点击展开加载全部代码(NowJava.com)