Hello Jason,
thank you for reply and explanation. Now it is very clear how it works now.
I have nothing to ask about current state of client, but have few ideas
about how it can be implemented/evolved.
1. Push the data received for paused partitions to user level API. Let user
decide what to do
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
