关于kafka:Linux解压安装Kafka

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