davidradl commented on code in PR #26789:
URL: https://github.com/apache/flink/pull/26789#discussion_r2206850307
##########
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:
- I see the Kafka script is run in Flink using:
$KAFKA_DIR/bin/kafka-topics.sh
do we not need to fully qualify it?
- can we tell the user where to get the Kafka docker image from.
--
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]
