connect-api-2.3.1-sources.jar

<dependency>
	<groupId>org.apache.kafka</groupId>
	<artifactId>connect-api</artifactId>
	<version>2.3.1</version>
	<classifier>sources</classifier>
	<type>java-source</type>
</dependency>

org.apache.kafka:connect-api:2.3.1

META-INF/MANIFEST.MF
LICENSE
NOTICE
org/apache/kafka/connect/util/ConnectorUtils.java
org/apache/kafka/connect/health/ConnectClusterDetails.java
org/apache/kafka/connect/health/ConnectorType.java
org/apache/kafka/connect/health/ConnectorHealth.java
org/apache/kafka/connect/health/ConnectClusterState.java
org/apache/kafka/connect/health/AbstractState.java
org/apache/kafka/connect/health/TaskState.java
org/apache/kafka/connect/health/ConnectorState.java
org/apache/kafka/connect/source/SourceConnector.java
org/apache/kafka/connect/source/SourceTask.java
org/apache/kafka/connect/source/SourceTaskContext.java
org/apache/kafka/connect/source/SourceRecord.java
org/apache/kafka/connect/sink/SinkTaskContext.java
org/apache/kafka/connect/sink/SinkTask.java
org/apache/kafka/connect/sink/SinkConnector.java
org/apache/kafka/connect/sink/SinkRecord.java
org/apache/kafka/connect/storage/SimpleHeaderConverter.java
org/apache/kafka/connect/storage/StringConverter.java
org/apache/kafka/connect/storage/HeaderConverter.java
org/apache/kafka/connect/storage/Converter.java
org/apache/kafka/connect/storage/OffsetStorageReader.java
org/apache/kafka/connect/storage/ConverterConfig.java
org/apache/kafka/connect/storage/ConverterType.java
org/apache/kafka/connect/storage/StringConverterConfig.java
org/apache/kafka/connect/components/Versioned.java
org/apache/kafka/connect/transforms/Transformation.java
org/apache/kafka/connect/connector/ConnectRecord.java
org/apache/kafka/connect/connector/Connector.java
org/apache/kafka/connect/connector/Task.java
org/apache/kafka/connect/connector/ConnectorContext.java
org/apache/kafka/connect/connector/policy/ConnectorClientConfigRequest.java
org/apache/kafka/connect/connector/policy/ConnectorClientConfigOverridePolicy.java
org/apache/kafka/connect/errors/AlreadyExistsException.java
org/apache/kafka/connect/errors/DataException.java
org/apache/kafka/connect/errors/ConnectException.java
org/apache/kafka/connect/errors/IllegalWorkerStateException.java
org/apache/kafka/connect/errors/SchemaBuilderException.java
org/apache/kafka/connect/errors/SchemaProjectorException.java
org/apache/kafka/connect/errors/NotFoundException.java
org/apache/kafka/connect/errors/RetriableException.java
org/apache/kafka/connect/data/Values.java
org/apache/kafka/connect/data/SchemaBuilder.java
org/apache/kafka/connect/data/Timestamp.java
org/apache/kafka/connect/data/Schema.java
org/apache/kafka/connect/data/Decimal.java
org/apache/kafka/connect/data/Time.java
#内容未全部加载，请点击展开加载全部代码(NowJava.com)