This is a known limitation, see
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:
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?