repos de kafka ruta de kafka https://drive.google.com/file/d/1KFMtGsOaU_sJwBFiScRZn-lmo9A8bgbl/view?usp=drive_link

extract the zip file copy the properties files and place it in config folder in kafka extract change the location in bat files as per your extracted kafka location

Make sure you are inside the bin/windows directory.

Start Zookeeper and Kafka Broker

Start up the Zookeeper.

zookeeper-server-start.bat ....\config\zookeeper.properties

Start up the Kafka Broker.

kafka-server-start.bat ....\config\server.properties

How to create a topic ?

kafka-topics.bat --create --topic test-topic -zookeeper localhost:2181 --replication-factor 1 --partitions 4

How to instantiate a Console Producer?

Without Key

kafka-console-producer.bat --broker-list localhost:9092 --topic test-topic

With Key

kafka-console-producer.bat --broker-list localhost:9092 --topic test-topic --property "key.separator=-" --property "parse.key=true"

How to instantiate a Console Consumer?

Without Key

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic --from-beginning

With Key

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic --from-beginning -property "key.separator= - " --property "print.key=true"

With Consumer Group

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic --group

[martes 10:18 a. m.] Siva Sreenivasa Rao D

Make sure you are inside the bin/windows directory.

List the topics in a cluster

kafka-topics.bat --zookeeper localhost:2181 --list

Describe topic

The below command can be used to describe all the topics.

kafka-topics.bat --zookeeper localhost:2181 --describe

The below command can be used to describe a specific topic.

kafka-topics.bat --zookeeper localhost:2181 --describe --topic

Alter the min insync replica

kafka-topics.bat --alter --zookeeper localhost:2181 --topic library-events --config min.insync.replicas=2

Delete a topic

kafka-topics.bat --zookeeper localhost:2181 --delete --topic

How to view consumer groups

kafka-consumer-groups.bat --bootstrap-server localhost:9092 --list

Consumer Groups and their Offset

kafka-consumer-groups.bat --bootstrap-server localhost:9092 --describe --group console-consumer-27773

Viewing the Commit Log

kafka-run-class.bat kafka.tools.DumpLogSegments --deep-iteration --files /tmp/kafka-logs/test-topic-0/00000000000000000000.log

Setting Up Multiple Kafka Brokers

The first step is to add a new server.properties.

We need to modify three properties to start up a multi broker set up.

broker.id=

listeners=PLAINTEXT://localhost:

log.dirs=/tmp/

Example config will be like below.

broker.id=1

listeners=PLAINTEXT://localhost:9093

log.dirs=/tmp/kafka-logs-1

Starting up the new Broker

Provide the new server.properties thats added.

kafka-server-start.bat ....\config\server-1.properties

kafka-server-start.bat ....\config\server-2.properties