В предыдущей статье автор рассказал как добавить возможность динамического определения топика в Kafka для каждого события.
В данной статье рассказывается, как протестировать stateless- и stateful-операторы Flink с помощью абстракций TestHarness.
⛓ Ссылка на статью
🔖 Предыдущая часть — КЛИК
📱 Java Developer | #статья