1. tar -zxvf kafka_2.11-2.1.0.tgz
    2. mv kafka_2.11-2.1.0 /usr/local/kafka
    3. cd /usr/local/kafka/config
    5. vim server.properties
    6. //配置文件
    7. log.dirs=/usr/local/kafka/kafka-logs
    9. cd /usr/local/kafka
    10. bin/kafka-server-start.sh config/server.properties //启动
    12. //另开一个终端
    13. cd /usr/local/kafka/bin
    14. ./kafka-topics.sh --create --topic attentionProductLog --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1
    15. ./kafka-topics.sh --create --topic buyCartProductLog --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1
    16. ./kafka-topics.sh --create --topic collectProductLog --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1
    17. ./kafka-topics.sh --create --topic scanProductLog --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1
    20. ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic attentionProductLog --from-beginning

    image.png