kafka安装包可以通过官网下载：将压缩包上传到/opt/目录下 解压缩文件
Apache Kafka
配置tar -zxvf kafka_2.11-1.0.0.tgz
kafka的配置文件在 config/server.proterties中要修改的参数如下
启动Zookeeper启动kafkacd /opt/kafka/bin/zookeeper-server-start.sh -daemon ../config/zookeeper.properties
查看是否启动cd /opt/kafka_2.11-1.0.0/bin ./kafka-server-start.sh -daemon ../config/server.properties
查看所有主题jps
创建主题cd /opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --list --zookeeper 192.168.222.130:2181
删除主题cd /opt/kafka/bin/kafka-topic.sh --create --zookeeper ip地址:2181 --partitions 1 --replication-factor 1 --topic 主题
启动生产者-发送消息cd /opt/kafka_2.11-1.0.0/bin/kafka-topics.sh --delete --zookeeper 192.168.224.130:2181 --topic test
启动消费者-拉取消息cd /opt/kafka/bin/kafka-console-producer.sh --broker-list ip地址:9092 --topic 主题
实时通讯
cd /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server ip地址:9092 --topic 主题
之前的内容也显示
cd /opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server ip地址:9092 --topic 主题 --from-beginning
