commit	6d2ec84ccc0ad22a1e46be54fb7a4952bcfaa924	[log] [tgz]
author	Jason Huynh <huynhja@gmail.com>	Wed Jan 22 21:35:00 2020 -0800
committer	Jason Huynh <huynhja@gmail.com>	Wed Jan 22 21:35:00 2020 -0800
tree	e04cf51e97ab86b138e5aa2922877323b82eea5c
parent	65c83c8e75a86e97caf6dc127ad510dff9f8b8ee [diff]

Added GeodeContext to handle cache related operations
Added GeodeConnectorConfig for shared configs
Moved packages

src/main/java/geode/kafka/GeodeConnectorConfig.java[Added - diff]
src/main/java/geode/kafka/LocatorHostPort.java[Renamed from src/main/java/kafka/LocatorHostPort.java - diff]
src/main/java/geode/kafka/sink/GeodeKafkaSink.java[Renamed from src/main/java/kafka/GeodeKafkaSink.java - diff]
src/main/java/geode/kafka/source/GeodeEvent.java[Renamed from src/main/java/kafka/GeodeEvent.java - diff]
src/main/java/geode/kafka/source/GeodeKafkaSource.java[Renamed from src/main/java/kafka/GeodeKafkaSource.java - diff]
src/main/java/geode/kafka/source/GeodeKafkaSourceListener.java[Renamed from src/main/java/kafka/GeodeKafkaSourceListener.java - diff]
src/main/java/geode/kafka/source/GeodeKafkaSourceTask.java[Added - diff]
src/main/java/kafka/GeodeConnectorConfig.java[Deleted - diff]
src/main/java/kafka/GeodeKafkaSourceTask.java[Deleted - diff]
src/test/java/geode/kafka/GeodeKafkaTestCluster.java[Renamed from src/test/java/kafka/GeodeKafkaTestCluster.java - diff]
src/test/java/geode/kafka/GeodeLocalCluster.java[Renamed from src/test/java/kafka/GeodeLocalCluster.java - diff]
src/test/java/geode/kafka/JavaProcess.java[Renamed from src/test/java/kafka/JavaProcess.java - diff]
src/test/java/geode/kafka/KafkaLocalCluster.java[Renamed from src/test/java/kafka/KafkaLocalCluster.java - diff]
src/test/java/geode/kafka/LocatorLauncherWrapper.java[Renamed from src/test/java/kafka/LocatorLauncherWrapper.java - diff]
src/test/java/geode/kafka/ServerLauncherWrapper.java[Renamed from src/test/java/kafka/ServerLauncherWrapper.java - diff]
src/test/java/geode/kafka/WorkerAndHerderCluster.java[Renamed from src/test/java/kafka/WorkerAndHerderCluster.java - diff]
src/test/java/geode/kafka/WorkerAndHerderWrapper.java[Renamed from src/test/java/kafka/WorkerAndHerderWrapper.java - diff]
src/test/java/geode/kafka/ZooKeeperLocalCluster.java[Renamed from src/test/java/kafka/ZooKeeperLocalCluster.java - diff]
src/test/java/geode/kafka/source/GeodeKafkaSourceTaskTest.java[Added - diff]
src/test/java/geode/kafka/source/GeodeKafkaSourceTest.java[Renamed from src/test/java/kafka/GeodeKafkaSourceTest.java - diff]
src/test/java/kafka/GeodeKafkaSourceTaskTest.java[Deleted - diff]

21 files changed

tree: e04cf51e97ab86b138e5aa2922877323b82eea5c

README.md

geode-kafka-connector