Package org.apache.kafka.connect.tools

package org.apache.kafka.connect.tools

Provides source and sink connector implementations used for testing

Classes

Class	Description
MockConnector	This connector provides support for mocking certain connector behaviors.
MockSinkConnector	Mock sink implementation which delegates to MockConnector.
MockSinkTask	Task implementation for MockSinkConnector.
MockSourceConnector	Mock source implementation which delegates to MockConnector.
MockSourceTask	Task implementation for MockSourceConnector.
SchemaSourceConnector	A simple source connector that is capable of producing static data with Struct schemas.
SchemaSourceTask	Task implementation for SchemaSourceConnector.
VerifiableSinkConnector	A connector primarily intended for system tests.
VerifiableSinkTask	Counterpart to VerifiableSourceTask that consumes records and logs information about each to stdout.
VerifiableSourceConnector	A connector primarily intended for system tests.
VerifiableSourceTask	A connector primarily intended for system tests.