-
Notifications
You must be signed in to change notification settings - Fork 370
Kafka_zookeeper_commands
/opt/kafka/bin/kafka-topics.sh --list --zookeeper localhost:2181
opt/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic /opt/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic ntpprod.learning.events.failed --from-beginning
/opt/kafka/bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic --time -1
/opt/kafka/bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic
/opt/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic --partitions 6
/opt/kafka/bin/kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file ~/sample.json --execute /opt/kafka/bin/kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file ~/sample.json --verify
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --partition --offset --topic
/opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic < pipeline_test_data.json
/opt/kafka/bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group
/opt/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic --config retention.ms=<>
rmr /brokers/topics/{topic_name} rmr /admin/delete_topics/{topic_name} OR sudo ./zookeeper-shell.sh localhost:2181 rmr /brokers/topics/your_topic
/opt/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic --config retention.ms=0
-
Describe the topic for which you want to increase the replication factor and check the replication factor count by using the below command.
- /opt/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic
-
Keep the below json in one file and fill out the topic name, partition number and replicas.
{ "version": 1, "partitions":[ {"topic":"ntpprod.telemetry.ingest","partition":0,"replicas":[3,1]}, {"topic":"ntpprod.telemetry.ingest","partition":1,"replicas":[1,2]}, {"topic":"ntpprod.telemetry.ingest","partition":2,"replicas":[2,3]}, {"topic":"ntpprod.telemetry.ingest","partition":3,"replicas":[3,1]} ] }