Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- ```java
- Producer<GenericRecord> producer = client.newProducer(Schema.generic(schemaInfo)).create();
- producer.newMessage()
- .value(schema.newRecordBuilder()
- .set("intField", 32)
- .build())
- .send();
- ```
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement