В предыдущей части мы реализовывали минимальное Flink-приложение с использованием фреймворка Spring. Запустили первую Flink-задачу в поднятом в docker-compose кластере, а также проверили корректность результата по соответствующим логам.
В этой статье решим реальную бизнес-задачу дедупликации данных в пайплайне Kafka-to-Kafka.
⛓ Ссылка на статью
🔖 Предыдущая часть — КЛИК
➡️ Java Developer | #статья