共计 1586 个字符，预计需要花费 4 分钟才能阅读完成。
Linux 解压装置 Kafka
MacBook Linux 装置 zookeeper
MacBook Linux 装置 Kafka
Kafka 依赖 Zookeeper
Kafka 依赖 Zookeeper, 能够独自装置 Zookeeper, 也能够间接启动 Kafka 包里自带的 Zookeeper
Kafka 装置
cd /data/software
#下载
wget http://mirror.bit.edu.cn/apache/kafka/2.0.1/kafka_2.11-2.0.1.tgz
wget http://mirror.bit.edu.cn/apache/kafka/2.1.1/kafka_2.11-2.1.1.tgz
tar -zxvf kafka_2.11-2.0.1.tgz
mv kafka_2.11-2.0.1 /data/apps/kafka_2.11-2.0.1
cd /data/apps/kafka_2.11-2.0.1/
批改配置
vim config/server.properties
listeners=PLAINTEXT://192.168.1.53:9092
留神:
该属性在 config/server.properties 中的形容如下：翻译过去就是 hostname 和端口是用来倡议给生产者和消费者应用的，如果没有设置，将会应用 listeners 的配置，如果 listeners 也没有配置，将应用 java.net.InetAddress.getCanonicalHostName() 来获取这个 hostname 和 port，对于 ipv4，根本就是 localhost 了。如果有设置 hostname 会去用 hostname 去连贯, 就会报错
advertised.listeners=PLAINTEXT://192.168.1.53:9092
delete.topic.enable=true
如果没有设置 delete.topic.enable=true，则调用 kafka 的 delete 命令无奈真正将 topic 删除，而是显示（marked for deletion）启动
nohup bin/kafka-server-start.sh config/server.properties >> log.file 2>&1 &Kafka 常用命令应用
bin/kafka-topics.sh --list --zookeeper localhost:2181 列表
bin/kafka-topics.sh --list --zookeeper 192.168.1.53:2181
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic inTopic 创立 topic
单机版 只能创立一个分区 replication-factor 1, 不然报错提醒 Replication factor: 3 larger than available brokers: 1
能够多个正本 partitions 2
bin/kafka-topics.sh --zookeeper 192.168.1.53:2181 --describe --topic inTopic 查看 topic 形容
bin/kafka-console-producer.sh --broker-list 192.168.1.53:9092 --topic my-topic 生产数据 输出数据
bin/kafka-console-consumer.sh --bootstrap-server 192.168.1.53:9092 --topic my-topic --from-beginning 生产数据
bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic my-topic 删除 topic正文完