Kafka ve Flink Veri Kalite Pipeline’ı

Kafka verilerini Flink ile işleyen streaming pipeline geliştirdim. Validation, DLQ, event-ID deduplication, watermark, checkpoint ve 1 dakikalık GMV pencereleri ekledim. GitHub: github.com/omerfeyzioglu/ecommerce_streaming_gmv_quality_platform