Hi Chong,
to my knowledge, neither Flink's built-in metrics nor the metrics of the
Kafka producer itself give you this number directly. If your sink is
chained (no serialization, no network) to another Flink operator, you could
take the numRecordsOut of this operator instead. It will tell you how
hi
i have a flink sql, reading record from kafka, then use table function do some
transformation, then produce to kafka.
i have found that in the flink web record received of the first subTask is
always 0 ,and the Records send of the last subTask is 0 as well.
i want to count how many r
