Added validator and replaced use of booleans with enum
authorNaburun Nag <nag@cs.wisc.edu>
Tue, 3 Mar 2020 21:24:43 +0000 (13:24 -0800)
committerNaburun Nag <nag@cs.wisc.edu>
Tue, 3 Mar 2020 21:24:43 +0000 (13:24 -0800)
commitf709b208ff2d005e8360eeb5adf521cf22c61446
tree9e9a7976824e72692b29c82b0cd25180703198da
parent645afd52237868ba85d519e3e58da943a77a05c6
Added validator and replaced use of booleans with enum
src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java
src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java
src/main/java/org/apache/geode/kafka/sink/GeodeSinkConnectorConfig.java
src/main/java/org/apache/geode/kafka/utils/EnumValidator.java [new file with mode: 0644]
src/main/java/org/apache/geode/kafka/utils/GeodeSinkConfigurationConstants.java
src/test/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTaskTest.java