Skip to content

Commit 46ebbb4

Browse files
committed
add converter
1 parent 5b3bcfa commit 46ebbb4

File tree

1 file changed

+1
-1
lines changed
  • kafka-connect-neo4j/src/main/kotlin/streams/kafka/connect/sink

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ import java.util.concurrent.TimeUnit
2323

2424

2525
class Neo4jService(private val config: Neo4jSinkConnectorConfig) {
26-
26+
private val converter = ValueConverter()
2727
private val log: Logger = LoggerFactory.getLogger(Neo4jService::class.java)
2828

2929
private val driver: Driver

0 commit comments

Comments
 (0)