Kafka环境搭建

发表于 | 分类于
字数统计: 189 | 阅读时长 ≈ 1

Kafka入门——Kafka环境搭建

1. 环境准备

下载Kafka

Kafka官方网站：http://kafka.apache.org

目前的最新版本是：kafka_2.12-2.0.0

2. 参数配置

配置server.properties

1
listeners=PLAINTEXT://localhost:9092

3. 基础命令

启动zoopkeeper 2181

1
2
cd /usr/local/kafka_2.12-2.0.0
bin/zookeeper-server-start.sh config/zookeeper.properties &

启动 kafka 9092

1
2
cd /usr/local/kafka_2.12-2.0.0
bin/kafka-server-start.sh config/server.properties &

创建 topic

1
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions partition_count --topic topic_name

partition_count：partition的数)
topic_name：topic名)

删除 topic

1
bin/kafka-topics.sh  --delete --zookeeper localhost:2181  --topic topic_name

查看数据

1
2
cd /usr/local/kafka_2.12-2.0.0
bin/kafka-run-class.sh kafka.tools.DumpLogSegments --files /tmp/kafka-logs/topic_name-0/00000000000000000000.log --print-data-log Dumping /tmp/kafka-logs/topic_name-0/00000000000000000000.log

topic_name：topic名称
日志的路径可以在配置文件server.properties中的log.dir看到