This is a known limitation, see
https://issues.apache.org/jira/browse/FLINK-7286 .
As a crude workaround you may either break the chain after the source /
before the sink, or query the numRecordsOut metric for the source /
numRecordsIn metric for the sink via the WebUI metrics tab or REST API.
On 25/03/2020 10:49, Jim Chen wrote:
Hi, all
When I use flink-connector-kafka-0.11 consume Kafka0.11, the Cluster
web's Received Record is always 0. However, the log is not empty. Any
one can help me?
image.png
