Flink не перенаправляет метрики Kafka, когда параллелизм больше 1
#apache-kafka #apache-flink #apache-kafka #apache-flink Вопрос: У меня есть задание Flink, которое считывает данные из Kafka (версия 0.9) и записывает в Redis. Я хочу отслеживать records-consumed-rate и records-lag-max метрики, передаваемые Kafka,…