DBZ-2410 Fix test.
This commit is contained in:
parent
c0d61f27fe
commit
d540d6d761
@ -126,9 +126,8 @@ public void testConfigs() {
|
|||||||
config = buildTaskConfig(CassandraConnectorConfig.COMMIT_LOG_POST_PROCESSING_ENABLED.name(), "false");
|
config = buildTaskConfig(CassandraConnectorConfig.COMMIT_LOG_POST_PROCESSING_ENABLED.name(), "false");
|
||||||
assertEquals(false, config.postProcessEnabled());
|
assertEquals(false, config.postProcessEnabled());
|
||||||
|
|
||||||
boolean shouldReprocessErrorCommitLogs = true;
|
config = buildTaskConfig(CassandraConnectorConfig.COMMIT_LOG_ERROR_REPROCESSING_ENABLED.name(), "true");
|
||||||
config = buildTaskConfig(CassandraConnectorConfig.COMMIT_LOG_ERROR_REPROCESSING_ENABLED.name(), shouldReprocessErrorCommitLogs);
|
assertTrue(config.errorCommitLogReprocessEnabled());
|
||||||
assertEquals(shouldReprocessErrorCommitLogs, config.errorCommitLogReprocessEnabled());
|
|
||||||
|
|
||||||
String transferClazz = "io.debezium.connector.cassandra.BlackHoleCommitLogTransfer";
|
String transferClazz = "io.debezium.connector.cassandra.BlackHoleCommitLogTransfer";
|
||||||
config = buildTaskConfig(CassandraConnectorConfig.COMMIT_LOG_TRANSFER_CLASS.name(), transferClazz);
|
config = buildTaskConfig(CassandraConnectorConfig.COMMIT_LOG_TRANSFER_CLASS.name(), transferClazz);
|
||||||
|
Loading…
Reference in New Issue
Block a user