Ashfaqbs commented on PR #34992: URL: https://github.com/apache/beam/pull/34992#issuecomment-3016390762
Hi Robert As discussed via email, this PR contributes a minimal Kafka-to-Kafka example in RAW byte format using Beam's YAML DSL. It's a simple pass-through pipeline that reads from an input Kafka topic and writes to an output topic without any transformation or decoding. This should serve as a helpful reference for users validating Kafka I/O integration with Beam YAML. ✅ Apache license header and description are included ✅ File is renamed to `kafka-to-kafka_example.yaml` to skip automated test execution (as the pipeline has no assertions and requires Kafka infra) ✅ All non-functional checks (RAT, Lint, Formatters, Docker, etc.) have passed ❌ The Python PreCommit test failures are unrelated and expected — they attempt to run YAMLs without assertable output Let me know if any further changes are needed. Thanks again for your time and review! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: github-unsubscr...@beam.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
