sink schema AVRO 发送代码

2020-12-28 本文已影响0人无我_a50f

Producer producerx = client.newProducer(Schema.AVRO(Test.class))
.topic(xtopic)
.create();