Skip navigation links
C D F I M N O P R S T V 

C

commitRecord(SourceRecord, RecordMetadata) - Method in class org.apache.kafka.connect.tools.VerifiableSourceTask
 
COMPLETE_RECORD_DATA_CONFIG - Static variable in class org.apache.kafka.connect.tools.VerifiableSourceTask
 
config() - Method in class org.apache.kafka.connect.tools.MockConnector
 
config() - Method in class org.apache.kafka.connect.tools.MockSinkConnector
 
config() - Method in class org.apache.kafka.connect.tools.MockSourceConnector
 
config() - Method in class org.apache.kafka.connect.tools.SchemaSourceConnector
 
config() - Method in class org.apache.kafka.connect.tools.VerifiableSinkConnector
 
config() - Method in class org.apache.kafka.connect.tools.VerifiableSourceConnector
 
CONNECTOR_FAILURE - Static variable in class org.apache.kafka.connect.tools.MockConnector
 

D

DEFAULT_FAILURE_DELAY_MS - Static variable in class org.apache.kafka.connect.tools.MockConnector
 
DELAY_MS_KEY - Static variable in class org.apache.kafka.connect.tools.MockConnector
 

F

flush(Map<TopicPartition, OffsetAndMetadata>) - Method in class org.apache.kafka.connect.tools.VerifiableSinkTask
 

I

ID_CONFIG - Static variable in class org.apache.kafka.connect.tools.SchemaSourceTask
 
ID_CONFIG - Static variable in class org.apache.kafka.connect.tools.VerifiableSinkTask
 
ID_CONFIG - Static variable in class org.apache.kafka.connect.tools.VerifiableSourceTask
 
initialize(ConnectorContext) - Method in class org.apache.kafka.connect.tools.MockSinkConnector
 
initialize(ConnectorContext, List<Map<String, String>>) - Method in class org.apache.kafka.connect.tools.MockSinkConnector
 
initialize(ConnectorContext) - Method in class org.apache.kafka.connect.tools.MockSourceConnector
 
initialize(ConnectorContext, List<Map<String, String>>) - Method in class org.apache.kafka.connect.tools.MockSourceConnector
 

M

MOCK_MODE_KEY - Static variable in class org.apache.kafka.connect.tools.MockConnector
 
MockConnector - Class in org.apache.kafka.connect.tools
This connector provides support for mocking certain connector behaviors.
MockConnector() - Constructor for class org.apache.kafka.connect.tools.MockConnector
 
MockSinkConnector - Class in org.apache.kafka.connect.tools
Mock sink implementation which delegates to MockConnector.
MockSinkConnector() - Constructor for class org.apache.kafka.connect.tools.MockSinkConnector
 
MockSinkTask - Class in org.apache.kafka.connect.tools
 
MockSinkTask() - Constructor for class org.apache.kafka.connect.tools.MockSinkTask
 
MockSourceConnector - Class in org.apache.kafka.connect.tools
Mock source implementation which delegates to MockConnector.
MockSourceConnector() - Constructor for class org.apache.kafka.connect.tools.MockSourceConnector
 
MockSourceTask - Class in org.apache.kafka.connect.tools
 
MockSourceTask() - Constructor for class org.apache.kafka.connect.tools.MockSourceTask
 
MULTIPLE_SCHEMA_CONFIG - Static variable in class org.apache.kafka.connect.tools.SchemaSourceTask
 

N

NAME_CONFIG - Static variable in class org.apache.kafka.connect.tools.SchemaSourceTask
 
NAME_CONFIG - Static variable in class org.apache.kafka.connect.tools.VerifiableSinkTask
 
NAME_CONFIG - Static variable in class org.apache.kafka.connect.tools.VerifiableSourceTask
 
NUM_MSGS_CONFIG - Static variable in class org.apache.kafka.connect.tools.SchemaSourceTask
 

O

org.apache.kafka.connect.tools - package org.apache.kafka.connect.tools
 

P

PARTITION_COUNT_CONFIG - Static variable in class org.apache.kafka.connect.tools.SchemaSourceTask
 
poll() - Method in class org.apache.kafka.connect.tools.MockSourceTask
 
poll() - Method in class org.apache.kafka.connect.tools.SchemaSourceTask
 
poll() - Method in class org.apache.kafka.connect.tools.VerifiableSourceTask
 
put(Collection<SinkRecord>) - Method in class org.apache.kafka.connect.tools.MockSinkTask
 
put(Collection<SinkRecord>) - Method in class org.apache.kafka.connect.tools.VerifiableSinkTask
 

R

reconfigure(Map<String, String>) - Method in class org.apache.kafka.connect.tools.MockSinkConnector
 
reconfigure(Map<String, String>) - Method in class org.apache.kafka.connect.tools.MockSourceConnector
 

S

SchemaSourceConnector - Class in org.apache.kafka.connect.tools
A simple source connector that is capable of producing static data with Struct schemas.
SchemaSourceConnector() - Constructor for class org.apache.kafka.connect.tools.SchemaSourceConnector
 
SchemaSourceTask - Class in org.apache.kafka.connect.tools
 
SchemaSourceTask() - Constructor for class org.apache.kafka.connect.tools.SchemaSourceTask
 
start(Map<String, String>) - Method in class org.apache.kafka.connect.tools.MockConnector
 
start(Map<String, String>) - Method in class org.apache.kafka.connect.tools.MockSinkConnector
 
start(Map<String, String>) - Method in class org.apache.kafka.connect.tools.MockSinkTask
 
start(Map<String, String>) - Method in class org.apache.kafka.connect.tools.MockSourceConnector
 
start(Map<String, String>) - Method in class org.apache.kafka.connect.tools.MockSourceTask
 
start(Map<String, String>) - Method in class org.apache.kafka.connect.tools.SchemaSourceConnector
 
start(Map<String, String>) - Method in class org.apache.kafka.connect.tools.SchemaSourceTask
 
start(Map<String, String>) - Method in class org.apache.kafka.connect.tools.VerifiableSinkConnector
 
start(Map<String, String>) - Method in class org.apache.kafka.connect.tools.VerifiableSinkTask
 
start(Map<String, String>) - Method in class org.apache.kafka.connect.tools.VerifiableSourceConnector
 
start(Map<String, String>) - Method in class org.apache.kafka.connect.tools.VerifiableSourceTask
 
stop() - Method in class org.apache.kafka.connect.tools.MockConnector
 
stop() - Method in class org.apache.kafka.connect.tools.MockSinkConnector
 
stop() - Method in class org.apache.kafka.connect.tools.MockSinkTask
 
stop() - Method in class org.apache.kafka.connect.tools.MockSourceConnector
 
stop() - Method in class org.apache.kafka.connect.tools.MockSourceTask
 
stop() - Method in class org.apache.kafka.connect.tools.SchemaSourceConnector
 
stop() - Method in class org.apache.kafka.connect.tools.SchemaSourceTask
 
stop() - Method in class org.apache.kafka.connect.tools.VerifiableSinkConnector
 
stop() - Method in class org.apache.kafka.connect.tools.VerifiableSinkTask
 
stop() - Method in class org.apache.kafka.connect.tools.VerifiableSourceConnector
 
stop() - Method in class org.apache.kafka.connect.tools.VerifiableSourceTask
 

T

TASK_FAILURE - Static variable in class org.apache.kafka.connect.tools.MockConnector
 
taskClass() - Method in class org.apache.kafka.connect.tools.MockConnector
 
taskClass() - Method in class org.apache.kafka.connect.tools.MockSinkConnector
 
taskClass() - Method in class org.apache.kafka.connect.tools.MockSourceConnector
 
taskClass() - Method in class org.apache.kafka.connect.tools.SchemaSourceConnector
 
taskClass() - Method in class org.apache.kafka.connect.tools.VerifiableSinkConnector
 
taskClass() - Method in class org.apache.kafka.connect.tools.VerifiableSourceConnector
 
taskConfigs(int) - Method in class org.apache.kafka.connect.tools.MockConnector
 
taskConfigs(int) - Method in class org.apache.kafka.connect.tools.MockSinkConnector
 
taskConfigs(int) - Method in class org.apache.kafka.connect.tools.MockSourceConnector
 
taskConfigs(int) - Method in class org.apache.kafka.connect.tools.SchemaSourceConnector
 
taskConfigs(int) - Method in class org.apache.kafka.connect.tools.VerifiableSinkConnector
 
taskConfigs(int) - Method in class org.apache.kafka.connect.tools.VerifiableSourceConnector
 
THROUGHPUT_CONFIG - Static variable in class org.apache.kafka.connect.tools.SchemaSourceTask
 
THROUGHPUT_CONFIG - Static variable in class org.apache.kafka.connect.tools.VerifiableSourceTask
 
TOPIC_CONFIG - Static variable in class org.apache.kafka.connect.tools.SchemaSourceTask
 
TOPIC_CONFIG - Static variable in class org.apache.kafka.connect.tools.VerifiableSourceTask
 

V

validate(Map<String, String>) - Method in class org.apache.kafka.connect.tools.MockSinkConnector
 
validate(Map<String, String>) - Method in class org.apache.kafka.connect.tools.MockSourceConnector
 
VerifiableSinkConnector - Class in org.apache.kafka.connect.tools
 
VerifiableSinkConnector() - Constructor for class org.apache.kafka.connect.tools.VerifiableSinkConnector
 
VerifiableSinkTask - Class in org.apache.kafka.connect.tools
Counterpart to VerifiableSourceTask that consumes records and logs information about each to stdout.
VerifiableSinkTask() - Constructor for class org.apache.kafka.connect.tools.VerifiableSinkTask
 
VerifiableSourceConnector - Class in org.apache.kafka.connect.tools
 
VerifiableSourceConnector() - Constructor for class org.apache.kafka.connect.tools.VerifiableSourceConnector
 
VerifiableSourceTask - Class in org.apache.kafka.connect.tools
A connector primarily intended for system tests.
VerifiableSourceTask() - Constructor for class org.apache.kafka.connect.tools.VerifiableSourceTask
 
version() - Method in class org.apache.kafka.connect.tools.MockConnector
 
version() - Method in class org.apache.kafka.connect.tools.MockSinkConnector
 
version() - Method in class org.apache.kafka.connect.tools.MockSinkTask
 
version() - Method in class org.apache.kafka.connect.tools.MockSourceConnector
 
version() - Method in class org.apache.kafka.connect.tools.MockSourceTask
 
version() - Method in class org.apache.kafka.connect.tools.SchemaSourceConnector
 
version() - Method in class org.apache.kafka.connect.tools.SchemaSourceTask
 
version() - Method in class org.apache.kafka.connect.tools.VerifiableSinkConnector
 
version() - Method in class org.apache.kafka.connect.tools.VerifiableSinkTask
 
version() - Method in class org.apache.kafka.connect.tools.VerifiableSourceConnector
 
version() - Method in class org.apache.kafka.connect.tools.VerifiableSourceTask
 
C D F I M N O P R S T V 
Skip navigation links