bin/kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 2
bin/kafka-topics.sh --list
bin/kafka-topics.sh --describe --topic my-topic
bin/kafka-console-producer.sh --topic my-topic --message "Hello, Kafka!"
bin/kafka-console-consumer.sh --topic my-topic --from-beginning
bin/kafka-topics.sh --alter --topic my-topic --partitions 510. 소비자 그룹 나열
bin/kafka-topics.sh --alter --topic my-topic --replication-factor 311. 소비자 그룹 세부 정보 보기
bin/kafka-topics.sh --delete --topic my-topic12. 소비자를 제거합니다. 소비자 그룹
bin/kafka-consumer-groups.sh --create --group my-group14. 소비자 그룹 삭제
bin/kafka-consumer-groups.sh --list15. Topic
bin/kafka-consumer-groups.sh --describe --group my-group16의 오프셋을 설정합니다. Kafka 클러스터
bin/kafka-consumer-groups.sh --join --group my-group --topic my-topic18. Kafka 클러스터를 종료합니다
bin/kafka-consumer-groups.sh --leave --group my-group --topic my-topic19. Kafka 클러스터의 구성을 내보냅니다
bin/kafka-consumer-groups.sh --delete --group my-group21. fka 클러스터 구성
bin/kafka-run-class kafka.tools.GetOffsetShell --topic my-topic --group my-group22. Kafka 클러스터 업그레이드
bin/kafka-run-class kafka.tools.OffsetResetTool --topic my-topic --group my-group --to-earliest23. Kafka 클러스터 다운그레이드
bin/kafka-server-start.sh --daemon --console.
위 내용은 일반적인 Kafka 명령을 사용하고 다양한 시나리오에 유연하게 대응하는 방법을 알아보세요.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!