DBZ-4419 Fix test failure
This commit is contained in:
parent
68d16c3188
commit
62e2fd48c4
@ -2034,7 +2034,9 @@ public void shouldProcessTruncateMessages() throws Exception {
|
|||||||
@SkipWhenDatabaseVersion(check = EqualityCheck.LESS_THAN, major = 11, reason = "TRUNCATE events only supported in PG11+ PGOUTPUT Plugin")
|
@SkipWhenDatabaseVersion(check = EqualityCheck.LESS_THAN, major = 11, reason = "TRUNCATE events only supported in PG11+ PGOUTPUT Plugin")
|
||||||
@SkipWhenDecoderPluginNameIsNot(value = SkipWhenDecoderPluginNameIsNot.DecoderPluginName.PGOUTPUT, reason = "Tests specifically that pgoutput handles TRUNCATE messages")
|
@SkipWhenDecoderPluginNameIsNot(value = SkipWhenDecoderPluginNameIsNot.DecoderPluginName.PGOUTPUT, reason = "Tests specifically that pgoutput handles TRUNCATE messages")
|
||||||
public void shouldProcessTruncateMessagesWhenSkippedOperationsIsSuppliedWithoutTruncate() throws Exception {
|
public void shouldProcessTruncateMessagesWhenSkippedOperationsIsSuppliedWithoutTruncate() throws Exception {
|
||||||
startConnector(builder -> builder.with(PostgresConnectorConfig.SKIPPED_OPERATIONS, "u"));
|
startConnector(builder -> builder
|
||||||
|
.with(PostgresConnectorConfig.SKIPPED_OPERATIONS, "u")
|
||||||
|
.with(PostgresConnectorConfig.TRUNCATE_HANDLING_MODE, PostgresConnectorConfig.TruncateHandlingMode.INCLUDE));
|
||||||
waitForStreamingToStart();
|
waitForStreamingToStart();
|
||||||
|
|
||||||
consumer = testConsumer(1);
|
consumer = testConsumer(1);
|
||||||
|
Loading…
Reference in New Issue
Block a user