If you're using the JsonConverter, it looks like you're seeing
https://issues.apache.org/jira/browse/KAFKA-3055. It's been fixed and will
be included in 0.9.0.1 (and 0.9.1.0, which is trunk).
-Ewen
On Sun, Feb 7, 2016 at 8:34 PM, Shiti Saxena <ssaxena....@gmail.com> wrote:
> Hi,
>
> When defining a Kafka pipeline I realized that the Schema of SinkRecord was
> not the same as its SourceRecord. I used the following code snippet.
>
> for(Field x :record.valueSchema().fields()){
> outputStream.println(x.name());
> }
>
>
> Is this the correct way to get the schema or am I missing something?
>
> SourceRecord schema was
>
> id
> name
> email
> department
> modified
> org.apache.kafka.connect.data.Struct@59d634b7
>
>
> but it's corresponding SinkRecord Schema was
>
> id
> department
> department
> department
> modified
> org.apache.kafka.connect.data.Struct@...
>
>
> Could someone please help me with getting the correct Schema? Or is this a
> bug in the Connect API?
>
--
Thanks,
Ewen
