projects / geode-kafka-connector.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 65c83c8) | patch
Added GeodeContext to handle cache related operations
authorJason Huynh <huynhja@gmail.com>
Thu, 23 Jan 2020 05:35:00 +0000 (21:35 -0800)
committerJason Huynh <huynhja@gmail.com>
Thu, 23 Jan 2020 05:35:00 +0000 (21:35 -0800)
commit6d2ec84ccc0ad22a1e46be54fb7a4952bcfaa924
treee04cf51e97ab86b138e5aa2922877323b82eea5ctree | snapshot
parent65c83c8e75a86e97caf6dc127ad510dff9f8b8eecommit | diff
Added GeodeContext to handle cache related operations
Added GeodeConnectorConfig for shared configs
Moved packages
20 files changed:
src/main/java/geode/kafka/GeodeConnectorConfig.java [new file with mode: 0644] blob
src/main/java/geode/kafka/LocatorHostPort.java [moved from src/main/java/kafka/LocatorHostPort.java with 95% similarity] diff | blob | history
src/main/java/geode/kafka/sink/GeodeKafkaSink.java [moved from src/main/java/kafka/GeodeKafkaSink.java with 98% similarity] diff | blob | history
src/main/java/geode/kafka/source/GeodeEvent.java [moved from src/main/java/kafka/GeodeEvent.java with 94% similarity] diff | blob | history
src/main/java/geode/kafka/source/GeodeKafkaSource.java [moved from src/main/java/kafka/GeodeKafkaSource.java with 67% similarity] diff | blob | history
src/main/java/geode/kafka/source/GeodeKafkaSourceListener.java [moved from src/main/java/kafka/GeodeKafkaSourceListener.java with 95% similarity] diff | blob | history
src/main/java/geode/kafka/source/GeodeKafkaSourceTask.java [new file with mode: 0644] blob
src/main/java/kafka/GeodeConnectorConfig.java [deleted file] blob | history
src/main/java/kafka/GeodeKafkaSourceTask.java [deleted file] blob | history
src/test/java/geode/kafka/GeodeKafkaTestCluster.java [moved from src/test/java/kafka/GeodeKafkaTestCluster.java with 99% similarity] diff | blob | history
src/test/java/geode/kafka/GeodeLocalCluster.java [moved from src/test/java/kafka/GeodeLocalCluster.java with 97% similarity] diff | blob | history
src/test/java/geode/kafka/JavaProcess.java [moved from src/test/java/kafka/JavaProcess.java with 98% similarity] diff | blob | history
src/test/java/geode/kafka/KafkaLocalCluster.java [moved from src/test/java/kafka/KafkaLocalCluster.java with 96% similarity] diff | blob | history
src/test/java/geode/kafka/LocatorLauncherWrapper.java [moved from src/test/java/kafka/LocatorLauncherWrapper.java with 98% similarity] diff | blob | history
src/test/java/geode/kafka/ServerLauncherWrapper.java [moved from src/test/java/kafka/ServerLauncherWrapper.java with 99% similarity] diff | blob | history
src/test/java/geode/kafka/WorkerAndHerderCluster.java [moved from src/test/java/kafka/WorkerAndHerderCluster.java with 95% similarity] diff | blob | history
src/test/java/geode/kafka/WorkerAndHerderWrapper.java [moved from src/test/java/kafka/WorkerAndHerderWrapper.java with 89% similarity] diff | blob | history
src/test/java/geode/kafka/ZooKeeperLocalCluster.java [moved from src/test/java/kafka/ZooKeeperLocalCluster.java with 98% similarity] diff | blob | history
src/test/java/geode/kafka/source/GeodeKafkaSourceTaskTest.java [moved from src/test/java/kafka/GeodeKafkaSourceTaskTest.java with 57% similarity] diff | blob | history
src/test/java/geode/kafka/source/GeodeKafkaSourceTest.java [moved from src/test/java/kafka/GeodeKafkaSourceTest.java with 93% similarity] diff | blob | history
Kafka connector for Apache Geode