public class BinlogSplitReader extends Object implements DebeziumReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>
SnapshotSplitReader read.| Constructor and Description |
|---|
BinlogSplitReader(StatefulTaskContext statefulTaskContext,
int subTaskId) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close the reader and releases all resources.
|
boolean |
isFinished()
Return the current split of the reader is finished or not.
|
Iterator<org.apache.kafka.connect.source.SourceRecord> |
pollSplitRecords()
Reads records from MySQL.
|
void |
stopBinlogReadTask() |
void |
submitSplit(MySqlSplit mySqlSplit)
Add to split to read, this should call only the when reader is idle.
|
public BinlogSplitReader(StatefulTaskContext statefulTaskContext, int subTaskId)
public void submitSplit(MySqlSplit mySqlSplit)
DebeziumReadersubmitSplit in interface DebeziumReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>public boolean isFinished()
DebeziumReaderisFinished in interface DebeziumReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>@Nullable public Iterator<org.apache.kafka.connect.source.SourceRecord> pollSplitRecords() throws InterruptedException
DebeziumReaderIterator will be returned if the data of split is on pulling.pollSplitRecords in interface DebeziumReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>InterruptedExceptionpublic void close()
DebeziumReaderclose in interface DebeziumReader<org.apache.kafka.connect.source.SourceRecord,MySqlSplit>public void stopBinlogReadTask()
Copyright © 2022 The Apache Software Foundation. All rights reserved.