Kafka 주제를 생성하는 단계: Kafka 명령 사용

Kafka 명령을 사용하여 주제를 만드는 단계

1. ZooKeeper 및 Kafka 서비스 시작

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

2. 주제 만들기

kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 1

3. 주제 보기

kafka-topics.sh --list

4. 보내기 주제 메시지

kafka-console-producer.sh --topic my-topic --message "Hello, world!"

5. 주제의 메시지 사용

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

특정 코드 예제

# 启动ZooKeeper服务
zookeeper-server-start.sh config/zookeeper.properties

# 启动Kafka服务
kafka-server-start.sh config/server.properties

# 创建主题
kafka-topics.sh --create --topic my-topic --partitions 3 --replication-factor 1

# 查看主题
kafka-topics.sh --list

# 向主题发送消息
kafka-console-producer.sh --topic my-topic --message "Hello, world!"

# 从主题消费消息
kafka-console-consumer.sh --topic my-topic --from-beginning

Notes

• 주제를 생성할 때 주제의 이름, 파티션 수와 복제본 수.
• 파티션 수에 따라 주제가 동시에 처리할 수 있는 메시지 수가 결정됩니다.
• 사본 수에 따라 해당 주제 데이터의 사본 수가 결정됩니다.
• 특정 주제에 메시지를 보낼 때 메시지의 키와 값을 지정해야 합니다.
• 주제의 메시지를 사용할 때 소비자 그룹을 지정할 수 있습니다. 소비자 그룹의 소비자는 주제의 메시지를 공동으로 소비합니다.

위 내용은 Kafka 주제를 생성하는 단계: Kafka 명령 사용의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!