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
Hi Team,
I am using the upsert-kafka table API connector of Apache Flink to consume
events from a kafka topic, I want to log the kafka payloads that are
consumed. Is there a way to log it?
My code looks as below:
EnvironmentSettings settings =
EnvironmentSettings.newInstance().inStreamingMode().
