1. Kafka 설치
KAFKA_HOME
를 Kafka 설치 디렉터리로 설정합니다. KAFKA_HOME
为Kafka安装目录。2. 启动ZooKeeper
$KAFKA_HOME/bin
目录。./zookeeper-server-start.sh config/zookeeper.properties
3. 启动Kafka服务器
$KAFKA_HOME/bin
目录。./kafka-server-start.sh config/server.properties
4. 创建主题
$KAFKA_HOME/bin
目录。./kafka-topics.sh --create --topic my-topic --partitions 1 --replication-factor 1
5. 发送消息
$KAFKA_HOME/bin
目录。./kafka-console-producer.sh --topic my-topic --message "Hello, world!"
6. 消费消息
$KAFKA_HOME/bin
目录。./kafka-console-consumer.sh --topic my-topic --from-beginning
7. 查询版本
$KAFKA_HOME/bin
ZooKeeper는 Kafka의 종속 항목이므로 Kafka를 시작하기 전에 시작해야 합니다.
🎜명령줄 터미널을 열고$KAFKA_HOME/bin
디렉터리로 이동하세요. 🎜🎜다음 명령을 실행하여 ZooKeeper를 시작하세요. 🎜🎜./kafka-version.sh
$KAFKA_HOME/bin
디렉터리로 이동하세요. 🎜🎜다음 명령을 실행하여 Kafka 서버를 시작합니다. 🎜🎜kafka-version.sh: version: 2.8.0 kafka-version: 2.8.0 kafka-storage: 2.8.0 kafka-clients: 2.8.0 kafka-streams: 2.8.0 kafka-connect: 2.8.0 kafka-admin: 2.8.0 kafka-tools: 2.8.0
$KAFKA_HOME/bin
디렉터리로 이동하세요. 🎜🎜다음 명령을 실행하여 주제를 생성합니다. 🎜🎜rrreee🎜🎜5. 메시지 보내기 🎜🎜🎜🎜 주제에 메시지를 보내려면 명령줄 터미널을 열고 $KAFKA_HOME/bin 디렉토리. 🎜🎜다음 명령을 실행하여 메시지를 보내세요. 🎜🎜rrreee🎜🎜6. 메시지 사용 🎜🎜🎜🎜주제에서 메시지를 사용하려면 명령줄 터미널을 열고 <code>$KAFKA_HOME/bin
으로 이동하세요. > 디렉토리. 🎜🎜다음 명령을 실행하여 메시지를 사용하세요. 🎜🎜rrreee🎜🎜7. 버전 쿼리 🎜🎜🎜🎜Kafka 서버 버전을 쿼리하려면 명령줄 터미널을 열고 $KAFKA_HOME/bin으로 이동하세요. 코드> 디렉토리. 🎜🎜다음 명령을 실행하여 버전을 쿼리하세요. 🎜🎜rrreee🎜🎜예제 출력🎜🎜rrreee
위 내용은 Kafka 버전 쿼리 사용 방법을 배우기 위한 단계별 가이드의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!