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

DBZ-1052 Fix test for offset size

Browse Source
This commit is contained in:
Jiri Pechanec 2020-01-23 13:05:13 +01:00 committed by Gunnar Morling
parent c0557b325b
commit e198cb0f45
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-sqlserver/src/test/java/io/debezium/connector/sqlserver/SnapshotIT.java
View File

@ -222,7 +222,7 @@ private void testStreaming() throws SQLException, InterruptedException {
final Struct value1 = (Struct) record1.value(); final Struct value1 = (Struct) record1.value();
assertRecord(key1, expectedKey1); assertRecord(key1, expectedKey1);
assertRecord((Struct) value1.get("after"), expectedRow1); assertRecord((Struct) value1.get("after"), expectedRow1);
assertThat(record1.sourceOffset()).hasSize(3); assertThat(record1.sourceOffset()).hasSize(4);
Assert.assertTrue(record1.sourceOffset().containsKey("change_lsn")); Assert.assertTrue(record1.sourceOffset().containsKey("change_lsn"));
Assert.assertTrue(record1.sourceOffset().containsKey("commit_lsn")); Assert.assertTrue(record1.sourceOffset().containsKey("commit_lsn"));