kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Shikhar Bhushan (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-4068) FileSinkTask - use JsonConverter to serialize
Date Sat, 20 Aug 2016 00:03:21 GMT
Shikhar Bhushan created KAFKA-4068:
--------------------------------------

             Summary: FileSinkTask - use JsonConverter to serialize
                 Key: KAFKA-4068
                 URL: https://issues.apache.org/jira/browse/KAFKA-4068
             Project: Kafka
          Issue Type: Improvement
          Components: KafkaConnect
            Reporter: Shikhar Bhushan
            Assignee: Shikhar Bhushan
            Priority: Minor


People new to Connect often try out hooking up e.g. a Kafka topic with Avro data to the file
sink connector, only to find the file contain values like:

{noformat}
org.apache.kafka.connect.data.Struct@ca1bf85a
org.apache.kafka.connect.data.Struct@c298db6a
org.apache.kafka.connect.data.Struct@44108fbd
{noformat}

This is because currently the {{FileSinkConnector}} is meant as a toy example that expects
the schema to be {{Schema.STRING_SCHEMA}}, though it just {{toString()}}'s the value without
verifying that. 

A better experience would probably be if we used {{JsonConverter.fromConnectData()}} for serializing
to the file.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message