Kafka本地单实例安装
下载安装
从国内镜像站点下载并安装Kafka安装包，以下载并安装v3.2.3版本为例。
$ tar -xzf kafka_2.12-3.2.3.tgz
$ cd kafka_2.12-3.2.3启动服务
如下命令均在Kafka安装目录${KAFKA_HOME}下执行。
启动ZooKeeper服务：
$ bin/zookeeper-server-start.sh config/zookeeper.properties启动本地Kafka服务：
$ bin/kafka-server-start.sh config/server.properties执行操作
创建指定名称的Topic：
$ bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092查看指定Topic信息：
$ bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092在控制台往指定Topic写入Kafka消息：
$ bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
This is my first event
This is my second event这种方式写入Kafka的消息字符个数不能超过最大值4095，否则报错。 如果消息字符个数大于最大值，则可以将消息先按行分隔写入文件，然后再通过Linux管道命令写入Kafka。
$ vim test_kafka_events.txt
This is my first event
This is my second event
$ cat test_kafka_events.txt | bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092在控制台读取指定Topic中的消息：
$ bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092
This is my first event
This is my second eventKafka相关完整文档详见：https://kafka.apache.org/documentation/ 。
本文参与 腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。
原始发表：2022-09-20，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录
腾讯云开发者
