davidradl commented on code in PR #26789: URL: https://github.com/apache/flink/pull/26789#discussion_r2206828306
########## docs/content/docs/dev/table/sql/examples/kafka-to-kafka/kafka-to-kafka.md: ########## @@ -0,0 +1,106 @@ +This example demonstrates how to use **Apache Flink SQL** to consume JSON messages from a Kafka topic, process the data by transforming and filtering it, and then produce the output to another Kafka topic. + +## Set Up Kafka Topics + +```bash +# Create input topic +docker exec -it docker-kafka-1 kafka-topics.sh \ + --create --topic i-topic \ + --bootstrap-server localhost:9092 \ + --partitions 1 --replication-factor 1 + +# Create output topic +docker exec -it docker-kafka-1 kafka-topics.sh \ + --create --topic o-topic \ + --bootstrap-server localhost:9092 \ + --partitions 1 --replication-factor 1 +```` + +## Producer Script + +Run the following Python script to send JSON messages to the `i-topic`. + +```bash +C:\tmp\flink-sql\kafka-scripts>python producer.py Review Comment: is this a windows specific section - I would have expected Unix style filenames in an example. -- 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
