У меня есть источник kafka, из которого мое приложение flink читает данные и обрабатывает их, я хочу добавить механизм сохранения точки flink, чтобы возобновить процесс с того места, где он был оставлен, а не ...

В настоящее время я работаю над семестровым проектом, где я должен узнать серию из трех событий. Нравится P - > R - > P У нас есть два разных типа событий, которые потребляются через разъем Kafka в ...