Seperated out Configuration into source and sink where appropriate
authorJason Huynh <huynhja@gmail.com>
Thu, 30 Jan 2020 22:43:03 +0000 (14:43 -0800)
committerJason Huynh <huynhja@gmail.com>
Thu, 30 Jan 2020 22:43:45 +0000 (14:43 -0800)
commitbdff4a20bb24af20623055176e60a2f1b1c2a1e0
tree55c6ac229c717da15b77cc74bc33a801935440d5
parentf24f02bdf08d203e8918d2f6cc0003dd1457f7dc
Seperated out Configuration into source and sink where appropriate
Added a few more tests
18 files changed:
build.gradle
settings.gradle
src/main/java/geode/kafka/GeodeConnectorConfig.java
src/main/java/geode/kafka/GeodeContext.java
src/main/java/geode/kafka/sink/BatchRecords.java
src/main/java/geode/kafka/sink/GeodeKafkaSink.java
src/main/java/geode/kafka/sink/GeodeKafkaSinkTask.java
src/main/java/geode/kafka/sink/GeodeSinkConnectorConfig.java [new file with mode: 0644]
src/main/java/geode/kafka/source/GeodeKafkaSource.java
src/main/java/geode/kafka/source/GeodeKafkaSourceTask.java
src/main/java/geode/kafka/source/GeodeSourceConnectorConfig.java [new file with mode: 0644]
src/test/java/geode/kafka/GeodeConnectorConfigTest.java
src/test/java/geode/kafka/WorkerAndHerderWrapper.java
src/test/java/geode/kafka/sink/BatchRecordsTest.java
src/test/java/geode/kafka/sink/GeodeKafkaSinkTaskTest.java [new file with mode: 0644]
src/test/java/geode/kafka/sink/GeodeKafkaSinkTest.java [new file with mode: 0644]
src/test/java/geode/kafka/source/GeodeKafkaSourceTaskTest.java
src/test/java/geode/kafka/source/GeodeSourceConnectorConfigTest.java [new file with mode: 0644]