diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/AdjustPrecisionAndScale.java b/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/AdjustPrecisionAndScale.java
index 6f3812f..25e6df3 100644
--- a/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/AdjustPrecisionAndScale.java
+++ b/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/AdjustPrecisionAndScale.java
@@ -43,7 +43,7 @@
         "the desired range.  Can set a max precision and max scale, as well as require a positive scale.")
 @DocumentationNote("The Confluent AvroConverter uses a default precision of 64 which can be too large " +
     "for some database systems.")
-public class AdjustPrecisionAndScale<R extends ConnectRecord<R>> extends BaseKeyValueTransformation<R> {
+public abstract class AdjustPrecisionAndScale<R extends ConnectRecord<R>> extends BaseKeyValueTransformation<R> {
   private static final Logger log = LoggerFactory.getLogger(AdjustPrecisionAndScale.class);
 
   public AdjustPrecisionAndScale(boolean isKey) {
diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ChangeCaseConfig.java b/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ChangeCaseConfig.java
index 9cce805..0d5006e 100644
--- a/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ChangeCaseConfig.java
+++ b/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ChangeCaseConfig.java
@@ -16,7 +16,7 @@
 package com.github.jcustenborder.kafka.connect.transform.common;
 
 import com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils;
-import com.github.jcustenborder.kafka.connect.utils.config.ValidEnum;
+import com.github.jcustenborder.kafka.connect.utils.config.validators.Validators;
 import com.google.common.base.CaseFormat;
 import org.apache.kafka.common.config.AbstractConfig;
 import org.apache.kafka.common.config.ConfigDef;
@@ -40,7 +40,7 @@ public ChangeCaseConfig(Map<?, ?> originals) {
 
   public static ConfigDef config() {
     return new ConfigDef()
-        .define(FROM_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, ValidEnum.of(CaseFormat.class), ConfigDef.Importance.HIGH, FROM_DOC)
-        .define(TO_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, ValidEnum.of(CaseFormat.class), ConfigDef.Importance.HIGH, TO_DOC);
+        .define(FROM_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, Validators.validEnum(CaseFormat.class), ConfigDef.Importance.HIGH, FROM_DOC)
+        .define(TO_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, Validators.validEnum(CaseFormat.class), ConfigDef.Importance.HIGH, TO_DOC);
   }
 }
diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ChangeTopicCaseConfig.java b/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ChangeTopicCaseConfig.java
index 3baee7f..a9424c7 100644
--- a/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ChangeTopicCaseConfig.java
+++ b/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/ChangeTopicCaseConfig.java
@@ -16,7 +16,7 @@
 package com.github.jcustenborder.kafka.connect.transform.common;
 
 import com.github.jcustenborder.kafka.connect.utils.config.ConfigUtils;
-import com.github.jcustenborder.kafka.connect.utils.config.ValidEnum;
+import com.github.jcustenborder.kafka.connect.utils.config.validators.Validators;
 import com.google.common.base.CaseFormat;
 import org.apache.kafka.common.config.AbstractConfig;
 import org.apache.kafka.common.config.ConfigDef;
@@ -46,7 +46,7 @@ public ChangeTopicCaseConfig(Map<?, ?> originals) {
 
   public static ConfigDef config() {
     return new ConfigDef()
-        .define(FROM_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, ValidEnum.of(CaseFormat.class), ConfigDef.Importance.HIGH, FROM_DOC)
-        .define(TO_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, ValidEnum.of(CaseFormat.class), ConfigDef.Importance.HIGH, TO_DOC);
+        .define(FROM_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, Validators.validEnum(CaseFormat.class), ConfigDef.Importance.HIGH, FROM_DOC)
+        .define(TO_CONFIG, ConfigDef.Type.STRING, ConfigDef.NO_DEFAULT_VALUE, Validators.validEnum(CaseFormat.class), ConfigDef.Importance.HIGH, TO_DOC);
   }
 }
diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/HeaderToField.java b/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/HeaderToField.java
index cdf9907..939f424 100644
--- a/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/HeaderToField.java
+++ b/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/HeaderToField.java
@@ -37,7 +37,7 @@
 @Title("HeaderToField")
 @Description("This transformation is used to copy the value of a header to a field in the key or " +
     "value of the record.")
-public class HeaderToField<R extends ConnectRecord<R>> extends BaseKeyValueTransformation<R> {
+public abstract class HeaderToField<R extends ConnectRecord<R>> extends BaseKeyValueTransformation<R> {
   private static final Logger log = LoggerFactory.getLogger(HeaderToField.class);
 
   HeaderToFieldConfig config;
diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/SetMaximumPrecision.java b/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/SetMaximumPrecision.java
index 56a4ca4..2da4d9b 100644
--- a/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/SetMaximumPrecision.java
+++ b/src/main/java/com/github/jcustenborder/kafka/connect/transform/common/SetMaximumPrecision.java
@@ -42,7 +42,7 @@
     "maximum precision specified.")
 @DocumentationNote("The Confluent AvroConverter uses a default precision of 64 which can be too large " +
     "for some database systems.")
-public class SetMaximumPrecision<R extends ConnectRecord<R>> extends BaseKeyValueTransformation<R> {
+public abstract class SetMaximumPrecision<R extends ConnectRecord<R>> extends BaseKeyValueTransformation<R> {
   private static final Logger log = LoggerFactory.getLogger(SetMaximumPrecision.class);
 
   public SetMaximumPrecision(boolean isKey) {