启动kafka并创建topic的命令
时间: 2023-05-12 16:06:39 浏览: 174
启动 Kafka 的命令是:
```
bin/kafka-server-start.sh config/server.properties
```
创建 topic 的命令是:
```
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic my-topic
```
其中,my-topic 是你要创建的 topic 名称。
相关问题
怎么设置在docker-compose启动kafka时创建topic
在Docker Compose中启动Kafka时,可以使用Kafka的命令行工具`kafka-topics.sh`来创建topic,并在Kafka服务的启动脚本中添加相应的命令。
具体操作步骤如下:
1. 在Kafka服务的启动脚本中添加创建topic的命令,如下所示:
```
services:
kafka:
image: wurstmeister/kafka
command:
- bash
- -c
- |
/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties &
sleep 10
/opt/kafka/bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic my-topic
tail -f /dev/null
```
在这个例子中,我们使用`kafka-topics.sh`命令创建了一个名为`my-topic`的topic,并且指定了`zookeeper`的地址、副本因子和分区数。
2. 保存修改后的`docker-compose.yml`文件,并启动Kafka服务。
这样,当Kafka服务启动时,就会自动创建一个名为`my-topic`的topic,并且可以开始使用它了。如果需要创建更多的topic,可以在启动脚本中添加相应的命令。
linux启动kafka命令
在Linux上启动Kafka命令如下:
1. 进入Kafka安装目录:cd kafka_2.12-2.8.
2. 启动Zookeeper服务:bin/zookeeper-server-start.sh config/zookeeper.properties
3. 启动Kafka服务:bin/kafka-server-start.sh config/server.properties
4. 创建一个主题:bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
5. 启动一个生产者:bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
6. 启动一个消费者:bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
以上是启动Kafka的基本命令,可以根据需要进行修改和扩展。