Fork me on GitHub
#jackdaw
<
2023-11-28
>
andrea.crotti10:11:02

Question in case someone knows, given an avro-encoded topic, is there a way to generate a list of https://kafka.apache.org/24/javadoc/org/apache/kafka/connect/sink/SinkRecord.html from that directly? Without having to specify the schema myself for example? I don't even need all the records, just enough to test a kafka connect plugin directly since it takes SinkRecords as input. Would be a lot easier than having to run the whole shebang and get kafka-connect to send the sink records to my plugin

andrea.crotti11:11:13

I can't actually find anything in jackdaw to fetch the avro schema from a schema registry, I guess I can use the schema registry API directly then