Ashfaqbs commented on code in PR #26789: URL: https://github.com/apache/flink/pull/26789#discussion_r2208029159
########## 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 \ Review Comment: Agreed — updated the topic names to input-topic and output-topic for clarity. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
