Skip to content

Commit 5ace1d8

Browse files
[jcustenborder#111] Use Validators.validEnum
1 parent db003be commit 5ace1d8

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ChangeCaseConfig.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
package com.github.jcustenborder.kafka.connect.transform.common;
1717

1818
import com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils;
19-
import com.github.jcustenborder.kafka.connect.utils.config.ValidEnum;
19+
import com.github.jcustenborder.kafka.connect.utils.config.validators.Validators;
2020
import com.google.common.base.CaseFormat;
2121
import org.apache.kafka.common.config.AbstractConfig;
2222
import org.apache.kafka.common.config.ConfigDef;
@@ -40,7 +40,7 @@ public ChangeCaseConfig(Map<?, ?> originals) {
4040

4141
public static ConfigDef config() {
4242
return new ConfigDef()
43-
.define(FROM_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, ValidEnum.of(CaseFormat.class), ConfigDef.Importance.HIGH, FROM_DOC)
44-
.define(TO_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, ValidEnum.of(CaseFormat.class), ConfigDef.Importance.HIGH, TO_DOC);
43+
.define(FROM_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, Validators.validEnum(CaseFormat.class), ConfigDef.Importance.HIGH, FROM_DOC)
44+
.define(TO_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, Validators.validEnum(CaseFormat.class), ConfigDef.Importance.HIGH, TO_DOC);
4545
}
4646
}

src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ChangeTopicCaseConfig.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
package com.github.jcustenborder.kafka.connect.transform.common;
1717

1818
import com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils;
19-
import com.github.jcustenborder.kafka.connect.utils.config.ValidEnum;
19+
import com.github.jcustenborder.kafka.connect.utils.config.validators.Validators;
2020
import com.google.common.base.CaseFormat;
2121
import org.apache.kafka.common.config.AbstractConfig;
2222
import org.apache.kafka.common.config.ConfigDef;
@@ -46,7 +46,7 @@ public ChangeTopicCaseConfig(Map<?, ?> originals) {
4646

4747
public static ConfigDef config() {
4848
return new ConfigDef()
49-
.define(FROM_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, ValidEnum.of(CaseFormat.class), ConfigDef.Importance.HIGH, FROM_DOC)
50-
.define(TO_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, ValidEnum.of(CaseFormat.class), ConfigDef.Importance.HIGH, TO_DOC);
49+
.define(FROM_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, Validators.validEnum(CaseFormat.class), ConfigDef.Importance.HIGH, FROM_DOC)
50+
.define(TO_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, Validators.validEnum(CaseFormat.class), ConfigDef.Importance.HIGH, TO_DOC);
5151
}
5252
}

0 commit comments

Comments
 (0)