The GitHub Actions job "Flink Connector Kafka CI" on flink-connector-kafka.git/main has succeeded. Run started by GitHub user bowenli86 (triggered by bowenli86).
Head commit for run: 12d4d4b8bd8ca1af07922ec6d2b34254a44cb2af / bowenli86 <[email protected]> [FLINK-39037] support query kafka cluster id as metadata in records of DynamicKafkaTableSource (#222) # Motivation Kafka cluster id is an essential constant to query in context of multi clusters of dynamic kafka source. ConsumerRecord includes topic/partition/offset but not Kafka cluster id. This PR adds an opt-in side-channel to inject cluster id into deserialization so SQL metadata can expose kafka_cluster correctly in dynamic multi-cluster reads. # What Changed - Added a new internal deserializer hook, Updated dynamic source reader flow - Extended table deserialization path - Updated table source metadata wiring - Added/updated tests: - Added DynamicKafkaSourceClusterMetadataITCase. - Added DynamicKafkaDeserializationSchemaTest. - Updated DynamicKafkaTableITCase with cluster metadata coverage. - Added docs Report URL: https://github.com/apache/flink-connector-kafka/actions/runs/22158603576 With regards, GitHub Actions via GitBox
