kafka 安装

# 安装kafka

### 下载解压

“`

wget http://mirrors.shu.edu.cn/apache/kafka/1.0.1/kafka_2.12-1.0.1.tgz

tar -zxvf kafka_2.12-1.0.1.tgz

cd kafka_2.12-1.0.1

“`

### 配置

配置kafka连接信息

“`

vim config/server.properties

“`

修改内容:

“`

# host.name 如果设置了它,会仅绑定这个地址。如果没有设置,则会绑定所有的网络接口,并提交一个给ZK。不推荐使用 只有当listeners没有设置时才有必要使用。

# advertised.host.name 会将hostname通知给生产者和消费者,在多网卡时需要设置该值为另一个ip地址。如果没有设置该值,则返回 配置项host.name设置的值,如果host.name没有设置则返回java.net.InetAddress.getCanonicalHostName()不推荐使用 只有当advertised.listeners或listeners没有设置时才有必要使用。

listeners=PLAINTEXT://你的内网ip:9092

“`

### 启动

“`

//这条命令不需要。因为之前另外安装了zookeeper

./bin/zookeeper-server-start.sh config/zookeeper.properties &

./bin/kafka-server-start.sh config/server.properties &

“`

### 校验

“`

# 生产者

bin/kafka-console-producer.sh –broker-list 你设置的ip:9092 –topic test

./bin/kafka-console-producer.sh –broker-list 192.168.18.244:9092 –topic test

# 消费者

bin/kafka-console-consumer.sh –bootstrap-server 你设置的ip:9092 –topic test –from-beginning

./bin/kafka-console-consumer.sh –bootstrap-server 192.168.18.244:9092 –topic test –from-beginning

“`

# 备注 (待补充)

    原文作者:刘立
    原文地址: https://zhuanlan.zhihu.com/p/38931475
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞