Кафка Подключается. Как установить размер пакета, который определяет, когда файл детали должен быть закрыт и запущен новый

#apache-kafka #apache-flink #apache-kafka-connect Вопрос: У меня есть работа Flink, которая читает темы Kafka avro и записывает файлы в HDFS. Для управления размером подвижного файла я использую размер набора - размер-размер-файл-приемник…

Продолжить чтениеКафка Подключается. Как установить размер пакета, который определяет, когда файл детали должен быть закрыт и запущен новый