>  기사  >  Java  >  일반적인 Kafka 명령을 사용하고 다양한 시나리오에 유연하게 대응하는 방법을 알아보세요.

일반적인 Kafka 명령을 사용하고 다양한 시나리오에 유연하게 대응하는 방법을 알아보세요.

王林
王林원래의
2024-01-31 21:22:06738검색

일반적인 Kafka 명령을 사용하고 다양한 시나리오에 유연하게 대응하는 방법을 알아보세요.

Kafka 학습 필수 사항: 일반적인 명령어를 숙지하고 다양한 시나리오에 쉽게 대처하세요

1. 주제 만들기

bin/kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 2

2. 주제 목록 보기

bin/kafka-topics.sh --list

3. 리

4. 메시지 생성

bin/kafka-topics.sh --describe --topic my-topic

5. 메시지 소비

bin/kafka-console-producer.sh --topic my-topic --message "Hello, Kafka!"

6. 파티션 수 변경

bin/kafka-console-consumer.sh --topic my-topic --from-beginning

7.

아아아아 9. 소비자 그룹 만들기

bin/kafka-topics.sh --alter --topic my-topic --partitions 5
10. 소비자 그룹 나열

bin/kafka-topics.sh --alter --topic my-topic --replication-factor 3
11. 소비자 그룹 세부 정보 보기

bin/kafka-topics.sh --delete --topic my-topic
12. 소비자를 제거합니다. 소비자 그룹

bin/kafka-consumer-groups.sh --create --group my-group
14. 소비자 그룹 삭제

bin/kafka-consumer-groups.sh --list
15. Topic

bin/kafka-consumer-groups.sh --describe --group my-group
16의 오프셋을 설정합니다. Kafka 클러스터

bin/kafka-consumer-groups.sh --join --group my-group --topic my-topic
18. Kafka 클러스터를 종료합니다

bin/kafka-consumer-groups.sh --leave --group my-group --topic my-topic
19. Kafka 클러스터의 구성을 내보냅니다

bin/kafka-consumer-groups.sh --delete --group my-group
21. fka 클러스터 구성

bin/kafka-run-class kafka.tools.GetOffsetShell --topic my-topic --group my-group
22. Kafka 클러스터 업그레이드

bin/kafka-run-class kafka.tools.OffsetResetTool --topic my-topic --group my-group --to-earliest
23. Kafka 클러스터 다운그레이드

bin/kafka-server-start.sh --daemon --console
.

위 내용은 일반적인 Kafka 명령을 사용하고 다양한 시나리오에 유연하게 대응하는 방법을 알아보세요.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.