官网
下载地址

解压

  • 解压到~/app目录：tar -zxvf kafka_2.12-2.5.0.tgz -C ~/app/
  • 添加KAFKA_HOME到环境变量(~/.bash_profile)
  1. export KAFKA_HOME=/home/hadoop/app/kafka_2.12-2.5.0
  2. export PATH=$KAFKA_HOME/bin:$PATH

  • 使配置生效：source ~/.bash_profile

    1. cd $KAFKA_HOME/config
    2. vi server.properties  
    3. log.dirs=/home/hadoop/app/tmp/kafka-logs

  • 启停

    1. // 启停Kafka
    2. kafka-server-start.sh -daemon $KAFKA_HOME/config/server.properties
    3. // 创建Topic
    4. kafka-topics.sh --create --zookeeper hadoop000:2181 --replication-factor 1 --partitions 1 --topic topic_flink
    5. // 创建生产者
    6. kafka-console-producer.sh --broker-list hadoop000:9092 --topic topic_flink
    7. // 创建消费者
    8. kafka-console-consumer.sh --bootstrap-server hadoop000:9092 --topic topic_flink