Kafka 安装和使用

• 安装

  cd /usr/app
  wget https://archive.apache.org/dist/kafka/0.8.1.1/kafka_2.10-0.8.1.1.tgz
  tar –zxvf kafka_2.10-0.8.1.1.tgz
  mv kafka_2.10-0.8.1.1 kafka2.10
  

• 配置

  cd /usr/app/kafka2.10
  #编辑配置文件server.properties
  vi /usr/app/kafka2.10/config/server.properties
  #添加下面两行
  host.name=hadoop11
  zookeeper.connect=hadoop11:2181,hadoop12:2181,hadoop13:2181
  
  #传到其余机器
  scp -r /usr/app/kafka2.10 root@hadoop12:/usr/app
  scp -r /usr/app/kafka2.10 root@hadoop13:/usr/app
  #复制完之后分别修改修改slave1、slave2的Kafka安装目录下的config/server.properties文件 broker.id
  # slave1
  broker.id=2
  # slave2
  broker.id=3
  

• 启动kfaka

  #启动 kafka 之前,需要启动 Zookeeper
  /usr/app/kafka2.10/bin/kafka-server-start.sh -daemon /usr/app/kafka2.10/config/server.properties&
  

  

  

  

• Kafka 命令行操作

  生产者接收用户的标准输入发送到 Kafka，消费者则一直尝试从 Kafka 中拉取生产的数据， 并打印到标准输出中。下面使用 Kafka 命令行客户端创建主题、 生产者与消费者，以测试 Kafka 集群能否正常使用。