Hi , I have been working on developing new Kafka connector ( Sink ) which pushes data to container from the kafka cluster.
I am pushing the data using kafka-avro-console-producer to one of the topics . At the time of fetching the records pushed ( using SinkRecord ) at the put method in the SinkTask. The output looks like below *org.apache.kafka.connect.data.Struct@ecb4d6ec* *org.apache.kafka.connect.data.Struct@ecb4d6ef* *org.apache.kafka.connect.data.Struct@ecb4d6dr* But the expected output is expected to be a json that is sent from the kafka-avro-console-producer . The output at the kafka-avro-console-consumer seems fine . Can I access the avro message directly from the SinkRecord or is there any other alternative for fetching the avro messages pushed using kafka-avro-console-producer This is the follow up for the question : https://groups.google.com/forum/#!topic/confluent-platform/xja60s2_TZk Please let me know Thanks, Rk
