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 >>
