Контрольные точки с источником в качестве EventHub с поддержкой kafka имеют тенденцию к превышению времени ожидания на пороге.Я использую FlinkKafkaConsumer011.Я установил конфигурацию тайм-аута контрольной точки на 15 минут, и они все еще кажутся тайм-аутами.Размер состояния минимален (КБ)
Хорошо ли интегрируется головка кафки в концентраторах событий с flink?Это проблема с фиксацией смещения в концентраторах событий?