Ashfaqbs commented on code in PR #26789: URL: https://github.com/apache/flink/pull/26789#discussion_r2208029759
########## 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 \ Review Comment: Yes, makes sense. I've added the full path /opt/kafka/bin/kafka-topics.sh in the Docker commands. -- 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
