Ashfaqbs opened a new pull request, #26789: URL: https://github.com/apache/flink/pull/26789
## What is the purpose of the change This PR adds a documentation example that demonstrates how to use Apache Flink SQL to build an end-to-end streaming pipeline using Kafka as both the source and the sink. The example illustrates: - How to define input and output Kafka tables using Flink SQL. - How to write a transformation query that filters and modifies the stream. - How to set up Kafka topics and verify the results using Python-based producer and consumer scripts. - A visual reference from the Flink UI job graph. ## Brief change log - Added `kafka-to-kafka.md` under `docs/content/docs/dev/table/sql/examples/` - Includes sample SQL statements, Kafka commands, Python integration ## Does this pull request potentially affect one of the following parts: - Dependencies: No - The public API: No - The documentation: **Yes** - The build system: No - The runtime per-job behavior: No ## Documentation This adds a new SQL usage example under: `docs/dev/table/sql/examples/kafka-to-kafka.md` -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
