JavaScript is disabled on your browser.
Skip navigation links
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
C
D
F
I
L
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.
LazySourceConnector
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
L
LazySourceConnector
- Class in
org.apache.kafka.connect.tools
LazySourceConnector()
- Constructor for class org.apache.kafka.connect.tools.
LazySourceConnector
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.
LazySourceConnector
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.
LazySourceConnector
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.
LazySourceConnector
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.
LazySourceConnector
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.
LazySourceConnector
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
L
M
N
O
P
R
S
T
V
Skip navigation links
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes