From 75bbfc00ba1c4cad778cfe2e3e3df2a6525cdf4b Mon Sep 17 00:00:00 2001 From: vafs98 <34161512+vafs98@users.noreply.github.com> Date: Mon, 17 Feb 2025 12:28:46 -0600 Subject: [PATCH] Update README.md Modified wrong ENV values. They were KAFAK_HOME when should be KAFKA_HOME. There was a typo. --- spark-kafka-integration/README.md | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/spark-kafka-integration/README.md b/spark-kafka-integration/README.md index 4fcd3ca..273fc3f 100644 --- a/spark-kafka-integration/README.md +++ b/spark-kafka-integration/README.md @@ -18,22 +18,22 @@ ## Creating a Kafka topic ```sh -$KAFAK_HOME/bin/kafka-topics.sh --create --bootstrap-server : --replication-factor 3 --partitions 5 --topic +$KAFKA_HOME/bin/kafka-topics.sh --create --bootstrap-server : --replication-factor 3 --partitions 5 --topic ``` ## Describe a Kafka topic ```sh -$KAFAK_HOME/bin/kafka-topics.sh --describe --bootstrap-server : --topic +$KAFKA_HOME/bin/kafka-topics.sh --describe --bootstrap-server : --topic ``` ## Producing messages to Kafka topic ```sh -$KAFAK_HOME/bin/kafka-console-producer.sh --bootstrap-server : --topic +$KAFKA_HOME/bin/kafka-console-producer.sh --bootstrap-server : --topic ``` ## Consuming messages from Kafka topic ```sh -$KAFAK_HOME/bin/kafka-console-consumer.sh --bootstrap-server : --topic --from-beginning +$KAFKA_HOME/bin/kafka-console-consumer.sh --bootstrap-server : --topic --from-beginning ``` ## Login to spark gateway node (for example mynode.host.com) and create the application deployment `/apps/spark/spark-kafka-integration` directory. @@ -80,4 +80,4 @@ $ scp run_spark_kafka_integration_app.sh username@mynode.host.com:/apps/spark/sp ```sh sh /apps/spark/spark-kafka-integration/run_spark_kafka_integration_app.sh -``` \ No newline at end of file +```