flink-streaming

Вопрос или проблема У меня есть работа Flink, которая потребляет данные из Kafka, и задача стабильно работает, когда пропускная способность Kafka составляет <= 1000 сообщений в секунду. Когда пропускная способность Kafka превышает 1000, например, при