Reworked region to topic and topic to region parsing
authorJason Huynh <huynhja@gmail.com>
Thu, 30 Jan 2020 00:38:29 +0000 (16:38 -0800)
committerJason Huynh <huynhja@gmail.com>
Thu, 30 Jan 2020 00:38:29 +0000 (16:38 -0800)
commitd4cf91517e2880ff5636144dccded9f183363ce6
tree5870b22940f2d95b16fb25036042171e8879a0e1
parent9746583899c196a48f5ecdc35955715ac239e440
Reworked region to topic and topic to region parsing
Tasks are assigned region to topic or topic to region groups
A task can handle multiple regions or multiple topics based on configuration
build.gradle
src/main/java/geode/kafka/GeodeConnectorConfig.java
src/main/java/geode/kafka/sink/GeodeKafkaSink.java
src/main/java/geode/kafka/source/GeodeKafkaSource.java
src/main/java/geode/kafka/source/GeodeKafkaSourceTask.java
src/test/java/geode/kafka/GeodeConnectorConfigTest.java
src/test/java/geode/kafka/GeodeKafkaTestCluster.java
src/test/java/geode/kafka/GeodeLocalCluster.java
src/test/java/geode/kafka/ServerLauncherWrapper.java
src/test/java/geode/kafka/WorkerAndHerderWrapper.java
src/test/java/geode/kafka/source/GeodeKafkaSourceTaskTest.java