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

DBZ-8105 Use new sink API to access original record

Browse Source
This commit is contained in:
Jiri Pechanec 2024-07-31 07:22:50 +02:00
parent edf14f113a
commit 772cc7e280
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcSinkConnectorTask.java
View File

@ -244,7 +244,7 @@ private String getOriginalTopicName(SinkRecord record) {
// Kafka Connect implementation at this point, it's a fair workaround.
//
if (record instanceof InternalSinkRecord) {
return ((InternalSinkRecord) record).originalRecord().topic();
return ((InternalSinkRecord) record).context().original().topic();
}
return null;
}