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

DBZ-1361 Restoring compatibility with Apache Kafka 1.x

Browse Source
This commit is contained in:
Gunnar Morling 2019-06-27 16:25:03 +02:00 committed by Jiri Pechanec
parent e95d656bca
commit a41fb30eaa
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
debezium-core/src/main/java/io/debezium/relational/history/KafkaDatabaseHistory.java
View File

@ -227,7 +227,8 @@ protected void recoverRecords(Consumer<HistoryRecord> records) {
endOffset = getEndOffsetOfDbHistoryTopic(endOffset, historyConsumer);
logger.debug("End offset of database history topic is {}", endOffset);
ConsumerRecords<String, String> recoveredRecords = historyConsumer.poll(this.pollInterval);
// DBZ-1361 not using poll(Duration) to keep compatibility with AK 1.x
ConsumerRecords<String, String> recoveredRecords = historyConsumer.poll(this.pollInterval.toMillis());
int numRecordsProcessed = 0;
for (ConsumerRecord<String, String> record : recoveredRecords) {