Worked on the numaproj/numaflow repository to deliver KafkaVersion support within the KafkaSource configuration, enabling explicit specification of Kafka broker versions. This feature required coordinated updates across YAML, Go, and Rust models, ensuring that the Sarama client in Go could be configured to match the selected Kafka version for improved compatibility. The approach enhanced the stability and reliability of streaming pipelines by reducing runtime errors related to version mismatches. The work demonstrated proficiency in cross-language model updates and version-aware client configuration, leveraging skills in Go, Rust, and Kafka to address compatibility challenges in diverse deployment environments. No major bugs were addressed.