I am trying to registry and serialize an abject with flink, kafka, glue and
avro. I've seen this method which I'm trying.
Schema schema = parser.parse(new File("path/to/avro/file"));
GlueSchemaRegistryAvroSerializationSchema<GenericRecord> test=
GlueSchemaRegistryAvroSerializationSchema.forGeneric(schema, topic,
configs);
FlinkKafkaProducer<GenericRecord> producer = new
FlinkKafkaProducer<GenericRecord>(
kafkaTopic,
test,
properties);
My problem is that this system doesn't allow to include an object different
than *GenericRecord*, the object that I want to send is another and is very
big. So big that is too complex to transform to GenericRecord.
I don't find too much documentation. How can I send an object different
than GenericRecord, or any way to include my object inside GenericRecord?
--
Confidentiality Notice: This email and any files transmitted with it are
confidential and intended solely for the use of the individual or entity to
whom they are addressed. Additionally, this email and any files
transmitted with it may not be disseminated, distributed or copied. Please
notify the sender immediately by email if you have received this email by
mistake and delete this email from your system. If you are not the intended
recipient, you are notified that disclosing, copying, distributing or
taking any action in reliance on the contents of this information is
strictly prohibited.
--
<http://www.medallia.com/gartner-report/?source=Marketing%20-%20Email&utm_campaign=FY22Q4_NA_Gartner_MQ_VoC_Campaign&utm_medium=email&utm_source=email-signature&utm_content=report&utm_term=medallia-named-a-leader>
