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

[DBZ-1406] Remove unnecessary config key check.

Browse Source
This commit is contained in:
Bingqin Zhou 2019-08-19 23:02:05 -07:00 committed by Gunnar Morling
parent d8fca7b5cb
commit 7f526d4a32
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
debezium-connector-cassandra/src/main/java/io/debezium/connector/cassandra/CassandraConnectorConfig.java
View File

@ -340,8 +340,7 @@ public boolean postProcessEnabled() {
public CommitLogTransfer getCommitLogTransfer() {
try {
String clazz = configs.containsKey(COMMIT_LOG_TRANSFER_CLASS) ?
(String) configs.get(COMMIT_LOG_TRANSFER_CLASS) : DEFAULT_COMMIT_LOG_TRANSFER_CLASS;
String clazz = (String) configs.getOrDefault(COMMIT_LOG_TRANSFER_CLASS, DEFAULT_COMMIT_LOG_TRANSFER_CLASS);
CommitLogTransfer transfer = (CommitLogTransfer) Class.forName(clazz).newInstance();
transfer.init(commitLogTransferConfigs());
return transfer;