Kafka 버전 쿼리 사용 방법을 배우기 위한 단계별 가이드

1. Kafka 설치

• 서버에 Apache Kafka를 다운로드하여 설치합니다.
• Kafka 아카이브 파일을 추출합니다.
• 환경 변수 KAFKA_HOME를 Kafka 설치 디렉터리로 설정합니다. KAFKA_HOME为Kafka安装目录。

2. 启动ZooKeeper

• ZooKeeper是Kafka的依赖项，因此在启动Kafka之前必须先启动它。
• 打开命令行终端并导航到$KAFKA_HOME/bin目录。
• 运行以下命令启动ZooKeeper：

./zookeeper-server-start.sh config/zookeeper.properties

3. 启动Kafka服务器

• 打开命令行终端并导航到$KAFKA_HOME/bin目录。
• 运行以下命令启动Kafka服务器：

./kafka-server-start.sh config/server.properties

4. 创建主题

• 主题是Kafka中数据的逻辑分组。
• 要创建主题，请打开命令行终端并导航到$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服务器的版本，请打开命令行终端并导航到$KAFKA_HOME/bin
• 2. ZooKeeper 시작

ZooKeeper는 Kafka의 종속 항목이므로 Kafka를 시작하기 전에 시작해야 합니다.

🎜명령줄 터미널을 열고 $KAFKA_HOME/bin 디렉터리로 이동하세요. 🎜🎜다음 명령을 실행하여 ZooKeeper를 시작하세요. 🎜🎜

./kafka-version.sh

🎜🎜3. Kafka 서버를 시작하세요. 🎜🎜🎜🎜명령줄 터미널을 열고 $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

🎜🎜4. 주제 만들기 🎜🎜🎜🎜 주제는 Kafka의 논리적 데이터 그룹입니다. 🎜🎜테마를 만들려면 명령줄 터미널을 열고 $KAFKA_HOME/bin 디렉터리로 이동하세요. 🎜🎜다음 명령을 실행하여 주제를 생성합니다. 🎜🎜rrreee🎜🎜5. 메시지 보내기 🎜🎜🎜🎜 주제에 메시지를 보내려면 명령줄 터미널을 열고 $KAFKA_HOME/bin 디렉토리. 🎜🎜다음 명령을 실행하여 메시지를 보내세요. 🎜🎜rrreee🎜🎜6. 메시지 사용 🎜🎜🎜🎜주제에서 메시지를 사용하려면 명령줄 터미널을 열고 <code>$KAFKA_HOME/bin으로 이동하세요. > 디렉토리. 🎜🎜다음 명령을 실행하여 메시지를 사용하세요. 🎜🎜rrreee🎜🎜7. 버전 쿼리 🎜🎜🎜🎜Kafka 서버 버전을 쿼리하려면 명령줄 터미널을 열고 $KAFKA_HOME/bin으로 이동하세요. 코드> 디렉토리. 🎜🎜다음 명령을 실행하여 버전을 쿼리하세요. 🎜🎜rrreee🎜🎜예제 출력🎜🎜rrreee

위 내용은 Kafka 버전 쿼리 사용 방법을 배우기 위한 단계별 가이드의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!