Linux解压安装KafkaMacBookLinux安装zookeeperMacBookLinux安装KafkaKafka依赖ZookeeperKafka依赖Zookeeper，可以单独安装Zookeeper，也可以直接启动Kafka包自带的ZookeeperKafkaInstallcd/data/software#Downloadwgethttp://mirror.bit.edu。cn/apache/kafka/2.0.1/kafka_2.11-2.0.1.tgzwgethttp://mirror.bit.edu.cn/apache/kafka/2.1.1/kafka_2.11-2.1.1.tgztar-zxvfkafka_2.11-2.0.1.tgzmvkafka_2.11-2.0.1/data/apps/kafka_2.11-2.0.1cd/data/apps/kafka_2.11-2.0.1/修改配置vimconfig/server.propertieslisteners=PLAINTEXT://192.168.1.53:9092注意：config/server.properties中对该属性的描述如下：翻译过来就是hostname和port推荐给生产者和消费者。如果没有设置，会使用监听器的配置，如果没有配置监听器，会使用java.net.InetAddress.getCanonicalHostName()获取主机名和端口。对于ipv4，基本上就是localhost。如果设置了主机名，它将使用主机名进行连接，并会报错。advertised.listeners=PLAINTEXT://192.168.1.53:9092delete.topic.enable=true如果不设置delete.topic.enable=true，会调用kafka的delete命令，并不能真正删除topic，而是显示(标记为删除）启动nohupbin/kafka-server-start.shconfig/server.properties>>log.file2>&1&Kafka常用命令使用bin/kafka-topics.sh--list--zookeeperlocalhost:2181listbin/kafka-topics.sh--list--zookeeper192.168.1.53:2181bin/kafka-topics.sh--create--zookeeperlocalhost:2181--replication-factor1--partitions2--topicinTopic创建主题单机版只能创建一个partitionreplication-factor1，否则报错Replicationfactor:3largerthanavailablebrokers:1可以有多个副本分区2bin/kafka-topics.sh--zookeeper192.168.1.53:2181--describe--topicinTopic查看主题描述bin/kafka-console-producer.sh--broker-list192.168.1.53:9092--topicmy-topic生产数据输入数据bin/kafka-console-consumer.sh--bootstrap-server192.168.1.53:9092--topicmy-topic--from-beginning消费数据bin/kafka-topics.sh--delete--zookeeperlocalhost:2181--topicmy-topic删除主题
