Messages in Kafka Topic

Kafka Connect
1

Hi,

I had used a JDBC Source connector to fetch data from Netezza Database. I had used the convertor as JsonSchemaConvertor. When viewing the message in Kafdrop, it is showing in different way.

Required format:

{"name" : "cesho", "age": "XX"}

Received format:

J{"name" : "cesho", "age": "XX"}

I want to remove the letter J in front of the parantheses. Kindly help me to sort it out Forum :slight_smile: @rmoff

The config:

key.converter: io.confluent.connect.json.JsonSchemaConverter

key.converter.schema.registry.url: http://confluent-schema-registry:8081

value.converter: io.confluent.connect.json.JsonSchemaConverter

value.converter.schema.registry.url: http://confluent-schema-registry:8081

mode: bulk

table.whitelist: ZZ_CEANT_DEMO

topic.prefix: "demo-jdbc-json-"

numeric.mapping: best_fit

poll.interval.ms : 4800000

transforms: "flatten, renameTargetTopic"

transforms.flatten.type: "org.apache.kafka.connect.transforms.Flatten$Value"

transforms.flatten.delimiter: "."

transforms.renameTargetTopic.type: "org.apache.kafka.connect.transforms.RegexRouter"

transforms.renameTargetTopic.regex: "demo-jdbc-json-.*"

transforms.renameTargetTopic.replacement: "demo-jdbc-json"

Thanks,
Cesho

2

Is Kafdrop deserialising the JSON Schema correctly? That J looks like an ascii representation of the magic byte used by the Schema Registry. See Formats, Serializers, and Deserializers | Confluent Documentation

3

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.