kafka-server-start.sh config/server.properties
이 명령은 Kafka 브로커를 시작하고 config/server.properties
를 구성 파일로 사용합니다. config/server.properties
作为配置文件。
kafka-server-start.sh config/server-1.properties kafka-server-start.sh config/server-2.properties kafka-server-start.sh config/server-3.properties
该命令将启动三个Kafka Broker,并使用config/server-1.properties
、config/server-2.properties
和config/server-3.properties
作为配置文件。
zookeeper-server-start.sh config/zookeeper.properties
该命令将启动一个ZooKeeper服务器,并使用config/zookeeper.properties
作为配置文件。
kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2
该命令将创建一个名为test
的Topic,该Topic具有3个分区和2个副本因子。
kafka-console-producer.sh --topic test
该命令将启动一个控制台生产者,该生产者将数据发送到test
Topic。
kafka-console-consumer.sh --topic test --from-beginning
该命令将启动一个控制台消费者,该消费者将从test
kafka-server-stop.sh
config/server-1.properties
, config/server-2.properties
및 <를 사용합니다. code>config/server-3.properties를 구성 파일로 사용합니다. 3. ZooKeeper 시작zookeeper-server-stop.sh
config/zookeeper.properties
를 구성 파일로 사용합니다. 4. 주제 생성# 启动ZooKeeper zookeeper-server-start.sh config/zookeeper.properties # 启动Kafka Broker kafka-server-start.sh config/server-1.properties kafka-server-start.sh config/server-2.properties kafka-server-start.sh config/server-3.properties # 创建Topic kafka-topics.sh --create --topic test --partitions 3 --replication-factor 2 # 生产数据 kafka-console-producer.sh --topic test # 消费数据 kafka-console-consumer.sh --topic test --from-beginning # 停止Kafka kafka-server-stop.sh # 停止ZooKeeper zookeeper-server-stop.sh
test
라는 주제를 생성합니다. test
주제로 데이터를 보내는 콘솔 생성기를 시작합니다. test
주제의 시작 부분부터 데이터를 소비하는 콘솔 소비자를 시작합니다. 위 내용은 Kafka를 빠르게 마스터하기 위한 Kafka 시작 명령에 대한 심층 분석의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!