该仓库专注于让读者秒懂Flink组件，包含Flink实战代码和文档、200个Flink教程知识点，Flink Datastream、Flink Table、Flink Window、Flink State、Flink Checkpoint、Flink Metrics、Flink Memory、Flink on standalone /yarn/k8s、Flink SQL、Flink CEP、Flink CDC、Flink UDF、PyFlink、Flink新特性、Flink Partition、Flink Memory等知识点。详细链接请看：https ://mp.weixin.qq.com/mp /appmsgalbum?__biz=Mzg5NDY3NzIwMA==&action=g…

Examples Repo for my Current'24 talk "So you want to write a UDF for Flink?"

Isotope tracers in Kafka headers — propagated by producer/consumer interceptors, reported on by Flink SQL (latency, topology, drops, coverage). Runs on Confluent Platform and Confluent Cloud for Apache Flink.

Apache Flink UDF Example in Go