Можно ли использовать Flink с Kotlin?

У меня есть проект, где мне нужно передавать данные в реальном времени. Я написал данные инкремента в тему кафки. Теперь мне нужно прочитать эти данные и обработать их. Для этого я планирую использовать Flink.
Моя дилемма в том, что я не знаю ни Java, ни Scala, ни Kotlin. Мне нужно было бы изучить одного из них, чтобы использовать Флинка, и поскольку Котлин является последним из множества, я думал, что должен это узнать, но действительно ли он совместим с Флинком?
Я совершенно новичок в любых потоках данных, поэтому, пожалуйста, прошу прощения за любые ошибки в моем вопросе и, безусловно, исправьте меня, если я ошибаюсь.

Короткий ответ: вы можете использовать любой язык JVM для взаимодействия с Flink: java, kotlin, scala (и, возможно, даже что-то вроде groovy).

Тем не менее, у вас, вероятно, возникнут проблемы с поиском ответов на вопросы. Флинк официально поддерживает scala и java, поэтому я начну с любого из этих двух.

Наконец, kotlin, являющийся последним, не имеет никакого отношения к тому, насколько он хорош. Люди используют все три успешно. Это в основном вопрос предпочтения (если у вас нет специального варианта использования).

Intereting Posts
Java generics в Kotlin: используйте Java raw type в качестве параметра метода в Kotlin Компаратор как лямбда Задержка с изменением размера дочерних элементов RecyclerView Обработчик исключений не работает с `spring-boot-starter-data-rest` Не удается сохранить выбранное состояние зрения в BaseAdapter с помощью Kotlin Kotlin JS – преобразование строк в число? Ошибка компиляции, вызывающая метод расширения из другого метода расширения в Котлине «Код в интерфейсах» Котлин, как они избегают «смертельного алмаза смерти»? Как настроить задачу processResources в сборке Gradle Kotlin compileReleaseKotlin не работает с java.lang.ClassNotFoundException: com.sun.tools.javac.util.Context Компилятор Kotlin не найден с использованием плагина Gradle Создание классов Kotlin в Android Studio с использованием действий Почему я не могу добавить два номера в Котлин, используя этот исходный код? Создайте общий 2D-массив в Котлине Kotlin Pass в типе, который реализует параметризованный интерфейс