검은 원숭이의 집: Kafka 명령행 조작

1. 현재 서버의 모든 topic 보기

[victor@node1 kafka]$ bin/kafka-topics.sh --zookeeper node1:2181 --list

2. topic 만들기

[victor@node1 kafka]$ bin/kafka-topics.sh --zookeeper node1:2181 --create \
--replication-factor 4 --partitions 5 --topic first

옵션 설명--topic 정의 topic 이름 --replication-factor 정의 복사본 수 --partitions 정의 구분 수

3. topic 삭제

[victor@node1 kafka]$ bin/kafka-topics.sh --zookeeper node1:2181 --delete \
--topic first

비명 힌트: 서버가 필요합니다.속성에서 삭제를 설정합니다.topic.enable=true 그렇지 않으면 삭제나 재부팅만 표시합니다.

4. 메시지 보내기(생산자)

[victor@node1 kafka]$ bin/kafka-console-producer.sh --broker-list node1:9092 \
--topic first

> hello world
> datou datou

5. 소비 소식(소비자)

[victor@node2 kafka]$ bin/kafka-console-consumer.sh --zookeeper node1:2181 \
--from-beginning --topic first

비명 힌트: --from-beginning:first 테마에서 이전의 모든 데이터를 읽을 수 있습니다.업무 장면에 따라 이 설정을 추가할지 여부를 선택하십시오.

6. Topic에 대한 자세한 내용 보기

[victor@node1 kafka]$ bin/kafka-topics.sh --zookeeper node1:2181 --describe \
--topic first 
Topic:first PartitionCount:4    ReplicationFactor:3 Configs:
    Topic: first    Partition: 0    Leader: 0   Replicas: 0,1,2 Isr: 0,1,2
    Topic: first    Partition: 1    Leader: 1   Replicas: 1,2,0 Isr: 1,2,0
    Topic: first    Partition: 2    Leader: 2   Replicas: 2,0,1 Isr: 2,0,1
    Topic: first    Partition: 3    Leader: 0   Replicas: 0,2,1 Isr: 0,2,1