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 +```