ASF Git Repos - geode-kafka-connector.git/commit

Code improvements:

* Exceptions being thrown as ConnectException
* Return values are used.
* static analyzer recommendations are implemented.

Kafka connector for Apache Geode

src/main/java/org/apache/geode/kafka/converter/JsonPdxConverter.java		diff \| blob \| history
src/main/java/org/apache/geode/kafka/sink/BatchRecords.java		diff \| blob \| history
src/main/java/org/apache/geode/kafka/sink/GeodeKafkaSinkTask.java		diff \| blob \| history
src/main/java/org/apache/geode/kafka/sink/GeodeSinkConnectorConfig.java		diff \| blob \| history
src/main/java/org/apache/geode/kafka/source/GeodeKafkaSourceTask.java		diff \| blob \| history
src/main/java/org/apache/geode/kafka/utils/EnumValidator.java		diff \| blob \| history
src/main/resources/kafka-connect-geode-version.properties		diff \| blob \| history
src/test/java/org/apache/geode/kafka/converter/JsonPdxConverterDUnitTest.java		diff \| blob \| history
src/test/java/org/apache/geode/kafka/source/GeodeKafkaSourceTaskTest.java		diff \| blob \| history