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:


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

View raw message