问题描述:

I generate a Schema from my object with ReflectData.get().getSchema(MyObject.class)

From an instance of MyObject.class, say myObject and the schema generated above, say myObjectSchema, I want to generate a ProducerRecord/GenericRecord so I can send it to kafka with a producer. Does anyone know how to do that? They only have simple cases using GenericRecord to populate each and every field.

相关阅读:
Top