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.tgzwget http://mirror.bit.edu.cn/apache/kafka/2.1.1/kafka_2.11-2.1.1.tgztar -zxvf kafka_2.11-2.0.1.tgzmv kafka_2.11-2.0.1 /data/apps/kafka_2.11-2.0.1cd /data/apps/kafka_2.11-2.0.1/批改配置vim config/server.propertieslisteners=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:2181bin/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 2bin/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