Description

The project is created for keeping Flink samples (especially testing).

Versions

JDK 11, Gradle 7.5.1, Flink 1.17.0

Modules

• flink-simple User and Action are merged into UserAction by userId key;
  The module has Kafka sink and source; smoke, integration and unit tests are present.
• flink-broadcast Action field is filtered by Rule. Rule contains a list of allowed action names. Rule data stream is broadcasted;
  Sink and source are created in tests; integration and unit tests are present.
• flink-table repeats flink-simple project, but with using Table API
• kafka-tools consumer and producer