fixes #296: Fix Java 8 support (#297)

Author: conker84

common/src/main/kotlin/streams/utils/JSONUtils.kt

@@ -85,8 +85,8 @@ object JSONUtils {
 
     init {
         val module = SimpleModule("Neo4jKafkaSerializer")
-        StreamsUtils.ignoreExceptions({ module.addSerializer(Point::class.java, PointSerializer()) }, NoClassDefFoundError::class.java) // in case is loaded from
-        StreamsUtils.ignoreExceptions({ module.addSerializer(PointValue::class.java, PointValueSerializer()) }, NoClassDefFoundError::class.java) // in case is loaded from
+        StreamsUtils.ignoreExceptions({ module.addSerializer(Point::class.java, PointSerializer()) }, NoClassDefFoundError::class.java, UnsupportedClassVersionError::class.java) // in case is loaded from
+        StreamsUtils.ignoreExceptions({ module.addSerializer(PointValue::class.java, PointValueSerializer()) }, NoClassDefFoundError::class.java, UnsupportedClassVersionError::class.java) // in case is loaded from
         module.addSerializer(TemporalAccessor::class.java, TemporalAccessorSerializer())
         OBJECT_MAPPER.registerModule(module)
         OBJECT_MAPPER.disable(SerializationFeature.FAIL_ON_EMPTY_BEANS)

kafka-connect-neo4j/pom.xml

@@ -62,12 +62,6 @@
             <groupId>org.neo4j.driver</groupId>
             <artifactId>neo4j-java-driver</artifactId>
         </dependency>
-
-        <dependency>
-            <groupId>org.neo4j</groupId>
-            <artifactId>neo4j-values</artifactId>
-            <version>${neo4j.version}</version>
-        </dependency>
     </dependencies>
 
     <build>

kafka-connect-neo4j/src/main/kotlin/streams/kafka/connect/sink/Neo4jSinkConnectorConfig.kt

@@ -220,7 +220,7 @@ class Neo4jSinkConnectorConfig(originals: Map<*, *>): AbstractConfig(config(), o
                             .importance(ConfigDef.Importance.HIGH)
                             .defaultValue("bolt://localhost:7687")
                             .group(ConfigGroup.CONNECTION)
-                            .validator(Validators.validURI("bolt", "bolt+routing"))
+                            .validator(Validators.validURI("bolt", "bolt+routing", "neo4j"))
                             .build())
                     .define(ConfigKeyBuilder
                             .of(CONNECTION_POOL_MAX_SIZE, ConfigDef.Type.INT)

kafka-connect-neo4j/src/test/kotlin/streams/kafka/connect/sink/Neo4jSinkTaskTest.kt

@@ -7,9 +7,6 @@ import org.apache.kafka.connect.data.Timestamp
 import org.apache.kafka.connect.sink.SinkRecord
 import org.apache.kafka.connect.sink.SinkTask
 import org.apache.kafka.connect.sink.SinkTaskContext
-import org.junit.After
-import org.junit.Before
-import org.junit.Ignore
 import org.junit.Rule
 import org.junit.Test
 import org.mockito.Mockito.mock
@@ -24,7 +21,8 @@ import streams.service.sink.strategy.CUDNode
 import streams.service.sink.strategy.CUDNodeRel
 import streams.service.sink.strategy.CUDOperations
 import streams.service.sink.strategy.CUDRelationship
-import java.util.*
+import java.util.Date
+import java.util.UUID
 import java.util.stream.Collectors
 import java.util.stream.StreamSupport
 import kotlin.test.assertEquals