Kafka 관련 명령(윈도우즈 버전)

서버 시작

> bin\windows\kafka-server-start.bat config\server.properties

topic 만들기

> bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

토픽 보기

> bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

생산자를 가동하다

> bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test
#  

소비자 시작

> bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

다중 에이전트 클러스터 설정

> copy config/server.properties config/server-1.properties
> copy config/server.properties config/server-2.properties
#  config   server-1.properties   server-2.properties  
# broker.id ， 。 ， ， ， 
config/server-1.properties:
    broker.id=1
    listeners=PLAINTEXT://:9093
    log.dir=/tmp/kafka-logs-1
config/server-2.properties:
    broker.id=2
    listeners=PLAINTEXT://:9094
    log.dir=/tmp/kafka-logs-2

새 노드 시작

> bin\windows\kafka-server-start.bat config/server-1.properties
> bin\windows\kafka-server-start.bat config/server-2.properties

복사본 3, 섹션 1의 새 topic 만들기

> bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic

에이전트 상태 보기

> bin\windows\kafka-topics.bat --describe --zookeeper localhost:2181 --topic my-replicated-topic
#  
> Topic:my-replicated-topic   PartitionCount:1    ReplicationFactor:3 Configs:
> Topic: my-replicated-topic  Partition: 0    Leader: 1   Replicas: 1,2,0    Isr: 1,2,0
# leader： 。 
# replicas： ， leader follower
# isr： ， replicas 

노드processid 가져오기, 대응 프로세스 죽이기

> wmic process where "caption = 'java.exe' and commandline like '%server-1.properties%'" get processid
#  
> ProcessId
> 6016
#  pid 6016 
> taskkill /pid 6016 /f