一、下载下载地址：http://kafka.apache.org/downloads二、安装1、安装前准备安装JDK：在CentOS上安装JDK安装ZooKeeper：在CentOS上安装ZooKeeper2，解压shell>tar-zxvfkafka_2.12-2.2。0.tgz-C/usr/local/3,配置shell>cd/usr/local/kafka_2.12-2.2.0/configshell>vimserver.properties编辑以下内容#默认为/tmp/kafka-logs,可以删掉log.dirs=/usr/local/kafka_2.12-2.2.0/logs#监听地址，ifconfig查看到的本机真实地址，也可以不配置单节点listeners=PLAINTEXT://192.168.1.10:9092#打开评论，设置为外部可访问地址。可以是主机名，也可以是ip地址，但必须是连接kafka的其他机器可以访问的地址。简单的说就是“允许远程连接”#如果是局域网（内网，阿里云腾讯云的vpc等），直接设置成局域网ip就可以了#如果是云主机，直接通过访问kafka外网（一般不做，如果做的话）需要设置为Elasticip或者绑定域名#advertised.listeners=PLAINTEXT://tianranll.cn:9092advertised.listeners=PLAINTEXT://192.168.1.10:9092#zookeeper地址和端口号#如果是集群的话可能是这样的：hostname1:port1,hostname2:port2,hostname3:port3#如果是withchroot:hostname1:port1,hostname2:port2,hostname3:port3/chroot/pathzookeeper.connect=192.168.1.10:21813.启动和停止startshell>cd/usr/local/kafka_2.12-2.2.0shell>bin/kafka-server-start.sh-daemonconfig/server.prope如果rties使用kafka-manager，需要开启JMX_PORTshell>JMX_PORT=9999bin/kafka-server-start.sh-daemonconfig/server.propertiesstopshell>bin/kafka-server-stop.sh4.测试1，jps,确认kafka是否存在（或ps查看kafka相关进程）2.Zookeeper查看注册信息shell>cd/usr/local/zookeeper-3.5.3-beta/shell>bin/zkCli.sh[zk:localhost:2181（已连接）0]ls/brokers/ids[0][zk:localhost:2181（已连接）1]get/brokers/ids/0{"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://VM_2_24_centos:9092"],"jmx_port":-1,"host":"VM_2_24_centos","timestamp":"1585396767598","port":9092,"version":4}3.kafka命令创建topicshell>bin/kafka-topics.sh--create--bootstrap-serverlocalhost:9092--replication-factor1--partitions1--topictestViewtopicshell>bin/kafka-topics.sh--list--bootstrap-serverlocalhost:9092testproducer发送消息shell>bin/kafka-console-producer.sh--broker-listlocalhost:9092--topictest>Hello>Worldconsumerconsumesmessageshell>bin/kafka-console-consumer.sh--bootstrapp-serverlocalhost:9092--topictest--from-beginningHelloWorld
