Skip to content

Commit b1afd62

Browse files
committed
🚧 Elasticsearch
1 parent 59ff1bb commit b1afd62

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

markdown-file/Kafka-Install-And-Settings.md

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -455,11 +455,10 @@ socket.request.max.bytes=104857600
455455
- 后台方式运行 kafka 服务:`cd /usr/local/kafka && bin/kafka-server-start.sh -daemon config/server.properties`
456456
- 停止 kafka 服务:`cd /usr/local/kafka && bin/kafka-server-stop.sh`
457457
- 再开一个终端测试:
458-
- 进入目录:`cd /usr/local/kafka`
459-
- 创建 topic 命令:`bin/kafka-topics.sh --create --zookeeper youmeekhost:2181 --replication-factor 1 --partitions 1 --topic my-topic-test`
460-
- 查看 topic 命令:`bin/kafka-topics.sh --list --zookeeper youmeekhost:2181`
461-
- 删除 topic:`bin/kafka-topics.sh --delete --topic my-topic-test --zookeeper youmeekhost:2181`
462-
- 给 topic 发送消息命令:`bin/kafka-console-producer.sh --broker-list youmeekhost:9092 --topic my-topic-test`,然后在出现交互输入框的时候输入你要发送的内容
458+
- 创建 topic 命令:`cd /usr/local/kafka && bin/kafka-topics.sh --create --zookeeper youmeekhost:2181 --replication-factor 1 --partitions 1 --topic my-topic-test`
459+
- 查看 topic 命令:`cd /usr/local/kafka && bin/kafka-topics.sh --list --zookeeper youmeekhost:2181`
460+
- 删除 topic:`cd /usr/local/kafka && bin/kafka-topics.sh --delete --topic my-topic-test --zookeeper youmeekhost:2181`
461+
- 给 topic 发送消息命令:`cd /usr/local/kafka && bin/kafka-console-producer.sh --broker-list youmeekhost:9092 --topic my-topic-test`,然后在出现交互输入框的时候输入你要发送的内容
463462
- 再开一个终端,进入 kafka 容器,接受消息:`cd /usr/local/kafka && bin/kafka-console-consumer.sh --bootstrap-server youmeekhost:9092 --topic my-topic-test --from-beginning`
464463
- 此时发送的终端输入一个内容回车,接受消息的终端就可以收到。
465464
- Spring Boot 依赖:

0 commit comments

Comments
 (0)