Kafka Basic Commands

Kafka Basic Commands

Rony S. Rony S.

Rony S.

Principal Solutions Architect | Certified Enterprise Architect | Head of Engineer | Professional Lecturer | Expert IT Consultant | Author | Speaker | Researcher | Freelancer

发布日期: 2023年6月27日
+ 关注

====================BASIC KAFKA COMMANDS===================


===========================================================

START ZOOKEEPER

===========================================================

bin/zookeeper-server-start.sh config/zookeeper.properties


===========================================================

GET INFORMATION FROM ZOOKEEPER ABOUT ACTIVE BROKER IDS

===========================================================

bin/zookeeper-shell.sh localhost:2181 ls /brokers/ids


===========================================================

GET INFORMATION FROM ZOOKEEPER ABOUT SPECIFIC BROKER BY ID

===========================================================

bin/zookeeper-shell.sh localhost:2181 get /brokers/ids/0


===========================================================

START KAFKA BROKER

===========================================================

bin/kafka-server-start.sh config/server.properties


bin/kafka-server-start.sh config/server0.properties

bin/kafka-server-start.sh config/server1.properties

bin/kafka-server-start.sh config/server2.properties


===========================================================

CREATE TOPIC

===========================================================

bin/kafka-topics.sh \

--bootstrap-server localhost:9092 \

--create \

--replication-factor 1 \

--partitions 3 \

--topic topic-test


bin/kafka-topics.sh \

--bootstrap-server localhost:9092,localhost:9093,localhost:9094 \

--create \

--replication-factor 3 \

--partitions 5 \

--topic topic-test


bin/kafka-topics.sh \

--bootstrap-server localhost:9092 \

--create \

--replication-factor 3 \

--partitions 100 \

--topic topic-test


===========================================================

LIST TOPICS

===========================================================

bin/kafka-topics.sh \

--bootstrap-server localhost:9092 \

--list


bin/kafka-topics.sh \

--bootstrap-server localhost:9092 \

--list


===========================================================

TOPIC DETAILS

===========================================================

bin/kafka-topics.sh \

--bootstrap-server localhost:9092 \

--describe \

--topic topic-test


bin/kafka-topics.sh \

--bootstrap-server localhost:9092,localhost:9093,localhost:9094 \

--describe \

--topic topic-test


bin/kafka-topics.sh \

--bootstrap-server localhost:9092 \

--describe \

--topic topic-test


===========================================================

START CONSOLE PRODUCER

===========================================================

bin/kafka-console-producer.sh \

--broker-list localhost:9092 \

--topic topic-test


bin/kafka-console-producer.sh \

--broker-list localhost:9092,localhost:9093,localhost:9094 \

--topic topic-test


bin/kafka-console-producer.sh \

--broker-list localhost:9092 \

--topic topic-test


===========================================================

START CONSOLE CONSUMER

===========================================================

领英推荐

bin/kafka-console-consumer.sh \

--bootstrap-server localhost:9092 \

--topic topic-test


bin/kafka-console-consumer.sh \

--bootstrap-server localhost:9092,localhost:9093,localhost:9094 \

--topic topic-test


bin/kafka-console-consumer.sh \

--bootstrap-server localhost:9092 \

--topic topic-test


===========================================================

START CONSOLE CONSUMER AND READ FROM SPECIFIC PARTITION

===========================================================

bin/kafka-console-consumer.sh \

--bootstrap-server localhost:9092 \

--partition 2 \

--topic topic-test \

--from-beginning


bin/kafka-console-consumer.sh \

--bootstrap-server localhost:9092 \

--partition 4 \

--from-beginning \

--topic topic-test


===========================================================

START CONSOLE CONSUMER AND READ MESSAGES FROM BEGINNING

===========================================================

bin/kafka-console-consumer.sh \

--bootstrap-server localhost:9092 \

--topic topic-test \

--from-beginning


bin/kafka-console-consumer.sh \

--bootstrap-server localhost:9092,localhost:9093,localhost:9094 \

--topic topic-test \

--from-beginning


bin/kafka-console-consumer.sh \

--bootstrap-server localhost:9092 \

--topic topic-test \

--from-beginning


===========================================================

START CONSOLE CONSUMER WITH SPECIFIC CONSUMER GROUP

===========================================================

bin/kafka-console-consumer.sh \

--bootstrap-server localhost:9092 \

--topic topic-test \

--group group-test \

--from-beginning


===========================================================

START CONSOLE CONSUMER AND READ MESSAGES FROM SPECIFIC OFFSET FROM SPECIFIC PARTITION

===========================================================

bin/kafka-console-consumer.sh \

--bootstrap-server localhost:9092 \

--partition 2 \

--topic topic-test \

--offset 0


===========================================================

LIST CONSUMER GROUPS

===========================================================

bin/kafka-consumer-groups.sh \

--bootstrap-server localhost:9092 \

--list


===========================================================

CONSUMER GROUP DETAILS

===========================================================

bin/kafka-consumer-groups.sh \

--bootstrap-server localhost:9092 \

--group group-test \

--describe


===========================================================

PRODUCER PERFORMANCE TEST

===========================================================

bin/kafka-producer-perf-test.sh \

--topic topic-test \

--num-records 1000 \

--throughput 10 \

--record-size 1000 \

--producer-props \

bootstrap.servers=localhost:9092


===========================================================

CONSUMER PERFORMANCE TEST

===========================================================

bin/kafka-consumer-perf-test.sh \

--broker-list localhost:9092 \

--topic topic-test \

--messages 1000000

要查看或添加评论，请登录

Rony S.的更多文章

  • What must we have as a Software Architect
    2024年3月28日

    What must we have as a Software Architect

    Software Architect adalah sebuah profesi yang terbilang kurang populer. Tapi, kebutuhan akan Software Architect ini…

  • Big O - Asymptotic Analysis
    2022年12月26日

    Big O - Asymptotic Analysis

    Hi, kembali lagi bersama saya rony, seorang software engineer yang mempunyai salah satu mimpi untuk dapat menulis buku…

    4 条评论
  • Basic Microservices Architecture Design
    2022年10月31日

    Basic Microservices Architecture Design

    Pada kesempatan kali ini akan sangat menarik karena saya diminta untuk mengisi materi di Telkom University yang…

    3 条评论
  • Chapter 7 - Docker in Continuous Integration & Deployment Practice #Docker-7
    2022年5月26日

    Chapter 7 - Docker in Continuous Integration & Deployment Practice #Docker-7

    Hi all, saya masih setia bersama teman-teman semua untuk mengarungi Docker World. Dan tentu petualangan kita akan…

  • Docker in Software Development Workflow #Docker-6
    2021年10月26日

    Docker in Software Development Workflow #Docker-6

    Yes, kita bertemu lagi di chapter 6 yang semakin seru saja. Semoga semuanya sudah khatam ya dari chapter 1 sampai…

  • Docker Compose in Action #Docker-5
    2021年10月4日

    Docker Compose in Action #Docker-5

    Hi pecinta teknologi dan petani kode. Mari kita tambah lagi pupuk kita tentang Docker agar panen pengetahuan kita…

  • Using Docker in Real Project Application #Docker-4
    2021年9月25日

    Using Docker in Real Project Application #Docker-4

    Halo semuanya, ketemu lagi di chapter 4 dan masih dengan saya, seseorang asli Solo yang kata orang-orang udah hilang…

  • Custom Docker Image #Docker-3
    2021年9月13日

    Custom Docker Image #Docker-3

    Chapter 3 - Custom Docker Image Pada chapter 3 ini kita akan disuguhkan materi mengenai bagaimana kita dapat membuat…

  • Docker Client Interaction #Docker-2
    2021年9月5日

    Docker Client Interaction #Docker-2

    Chapter 2 - Docker Client Interaction Hi Folks, let's get through chapter 2 bersama saya, rony. Semoga kita senantiasa…

    3 条评论
  • The Docker Fundamental #Docker-1
    2021年8月30日

    The Docker Fundamental #Docker-1

    Chapter 1 - The Docker Fundamental Kembali lagi dengan saya rony, seorang software architect sekaligus developer bodoh…

    3 条评论

社区洞察

其他会员也浏览了