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?
