alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-3078 Use max.queue.size for fetch size

Browse Source
This commit is contained in:
Chris Cranford 2021-02-19 14:53:44 -05:00 committed by Gunnar Morling
parent 5ed242a674
commit dfdd0858dd
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java
View File

@ -58,9 +58,6 @@ public class LogMinerStreamingChangeEventSource implements StreamingChangeEventS
private static final Logger LOGGER = LoggerFactory.getLogger(LogMinerStreamingChangeEventSource.class);
// TODO: change this to use MAX_QUEUE_SIE as the default
private static final int LOG_MINING_VIEW_FETCH_SIZE = 10_000;
private final OracleConnection jdbcConnection;
private final EventDispatcher<TableId> dispatcher;
private final Clock clock;
@ -177,7 +174,7 @@ public void execute(ChangeEventSourceContext context) {
startLogMining(jdbcConnection, startScn, endScn, strategy, isContinuousMining, logMinerMetrics);
stopwatch.start();
miningView.setFetchSize(LOG_MINING_VIEW_FETCH_SIZE);
miningView.setFetchSize(connectorConfig.getMaxQueueSize());
miningView.setFetchDirection(ResultSet.FETCH_FORWARD);
miningView.setLong(1, startScn);
miningView.setLong(2, endScn);