File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
source/src/main/kotlin/org/neo4j/connectors/kafka/source Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -119,14 +119,14 @@ class Neo4jCdcTask : SourceTask() {
119119 it.value.map { topic ->
120120 val transformed = it.key.applyProperties(changeEvent)
121121 val transformedValue = transformed.toConnectValue()
122- val keySerializer =
122+ val keyStrategy =
123123 config.cdcTopicsToKeyStrategy.getOrDefault(topic, Neo4jCdcKeyStrategy .WHOLE_VALUE )
124124 SourceRecord (
125125 config.partition,
126126 mapOf (" value" to changeEvent.id.id),
127127 topic,
128- keySerializer .schema(transformedValue),
129- keySerializer .value(transformedValue),
128+ keyStrategy .schema(transformedValue),
129+ keyStrategy .value(transformedValue),
130130 transformedValue.schema(),
131131 transformedValue.value())
132132 })
You can’t perform that action at this time.
0 commit comments