Hi, elakiya
If you want to log the deserialize avro record, you should modify the code
in [1].
1.
https://github.com/apache/flink/blob/70e635983dc9aa4bd772042f34a04099256a8750/flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchema.java#L81
Best,
Ro
Hi. elaloya.
If you want to log some information about the kafka records, you can add
some logs in KafkaRecordEmitter.
If you want to know the information about the deserialized value, you
should add logs in the avro format.
Best,
Hang
elakiya udhayanan 于2023年7月19日周三 19:44写道：
> Hi Team,
>
> I
