Added JsonPdxConverter (#2)
authorDonal Evans <donalevans86@gmail.com>
Fri, 21 Feb 2020 00:06:53 +0000 (16:06 -0800)
committerGitHub <noreply@github.com>
Fri, 21 Feb 2020 00:06:53 +0000 (16:06 -0800)
commitbc637cdc3c49557e81b51f8b5e7f1d9e0b083789
treedd40b7dd4f4039ada8b06e6d034ffcdff45aa5e3
parent97a9f92b98ddce7eb3f23bad16aa118c28470d52
Added JsonPdxConverter (#2)

- Allows PdxInstance objects to be converted to JSON bytes when sourced
from a Geode region into a Kafka topic
- Allows JSON bytes to be converted to PdxInstance objects when sinked
into a Geode region from a Kafka topic
- Added unit and DUnit tests for JsonPdxConverter
- Added functionality to the test framework to specify custom key
converter, custom value converter and configuration properties for each
- Added TestObject class to allow validation of
serialization/deserialization

Authored-by: Donal Evans <doevans@pivotal.io>
src/main/java/org/apache/geode/kafka/GeodeConnectorConfig.java
src/main/java/org/apache/geode/kafka/GeodeContext.java
src/main/java/org/apache/geode/kafka/converter/JsonPdxConverter.java [new file with mode: 0644]
src/test/java/org/apache/geode/kafka/GeodeAsSinkDUnitTest.java
src/test/java/org/apache/geode/kafka/GeodeAsSourceDUnitTest.java
src/test/java/org/apache/geode/kafka/converter/JsonPdxConverterDUnitTest.java [new file with mode: 0644]
src/test/java/org/apache/geode/kafka/converter/JsonPdxConverterTest.java [new file with mode: 0644]
src/test/java/org/apache/geode/kafka/utilities/GeodeKafkaTestUtils.java
src/test/java/org/apache/geode/kafka/utilities/TestObject.java [new file with mode: 0644]
src/test/java/org/apache/geode/kafka/utilities/WorkerAndHerderCluster.java
src/test/java/org/apache/geode/kafka/utilities/WorkerAndHerderWrapper.java