Hi Hans, Thank you for your quick response, appreciate it.
In *kafka-connect* docker, I see below settings in *kafka-connect.properties* file in *kafka-connect *directory: key.converter.schemas.enable=false key.converter.schema.registry.url=http://kafka-schema-registry:<PORT> value.converter.schema.registry.url=http://kafka-schema-registry:<PORT> key.converter=org.apache.kafka.connect.json.JsonConverter value.converter=org.apache.kafka.connect.json.JsonConverter internal.value.converter.schemas.enable=false rest.advertised.host.name=kafka-connect internal.value.converter=org.apache.kafka.connect.json.JsonConverter internal.key.converter=org.apache.kafka.connect.json.JsonConverter And the settings in *schema-registry *directory of *kafka-connect *docker are as https://github.com/confluentinc/schema-registry/tree/master/config Should I consider any other settings for *kafka-connect* or *schema-registry* to get the real json object NOT string formatted/stringified json which has extra "\" and is not json any more? Best regards, Mina On Fri, Jun 2, 2017 at 11:18 AM, Hans Jespersen <h...@confluent.io> wrote: > > My earlier comment still applies but in Kafka Connect the equivalent of a > serializer/deserializer (serdes) is called a “converter”. > Check which converter you have configured for your source connector and if > it is overriding whatever the default converter is configured for the > connect worker it is running in. > > -hans > > > > > > On Jun 2, 2017, at 8:12 AM, Mina Aslani <aslanim...@gmail.com> wrote: > > > > Hi, > > > > I would like to add that I use kafka-connect and schema-registery > version ` > > 3.2.1-6`. > > > > Best regards, > > Mina > > > > On Fri, Jun 2, 2017 at 10:59 AM, Mina Aslani <aslanim...@gmail.com> > wrote: > > > >> Hi. > >> > >> Is there any way that I get the data into a Kafka topic in Json format? > >> The source that I ingest the data from have the data in Json format, > >> however when I look that data in the kafka topic, schema and payload > fields > >> are added and data is not in json format. > >> > >> I want to avoid implementing a transformer to get the data from the > topic > >> and publishes Json in another one. > >> > >> Your input is appreciated. > >> > >> Best regards, > >> Mina > >> > >
