Producer<GenericRecord> producer = client.newProducer(Schema.generic(schemaInfo)).create();
producer.newMessage()
.value(schema.newRecordBuilder()
.set("intField", 32)
.build())
.send();
Created
July 9, 2019 07:37
-
-
Save sijie/28d44f6992d4f4a3a723563b00bf9737 to your computer and use it in GitHub Desktop.
Generic Record Example
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment