一 下載

官網(wǎng) https://kafka.apache.org/downloads

wget https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.6.2/kafka_2.12-2.6.2.tgz
tar -xzf kafka_2.12-2.6.2.tgz

二 設置kafka用戶名密碼

1. 增加用戶密碼配置文件
   在config下面新建kafka_client_jaas.conf文件內(nèi)容如下

KafkaClient {  
org.apache.kafka.common.security.plain.PlainLoginModule required  
    username="admin"  
    password="admin";  
};

在config下面新建kafka_client_jaas.conf文件內(nèi)容如下

KafkaServer {
    org.apache.kafka.common.security.plain.PlainLoginModule required
        username="admin"
        password="admin"
        user_admin="admin";
};

2 修改啟動腳本
vim bin/kafka-server-start.sh

# 最上面加上(路徑改為自己的)
export KAFKA_OPTS="-Djava.security.auth.login.config=/opt/kafka/config/kafka_server_jaas.conf"

vim bin/kafka-console-producer.sh , vim bin/kafka-console-consumer.sh

最上面加上(路徑改為自己的)
export KAFKA_OPTS="-Djava.security.auth.login.config=/opt/kafka/config/kafka_client_jaas.conf"

3 修改配置文件
vim config/server.properties

# 必須使用真實ip地址
listeners=SASL_PLAINTEXT://192.168.1.110:9092

#使用的認證協(xié)議
security.inter.broker.protocol=SASL_PLAINTEXT
#SASL機制
sasl.enabled.mechanisms=PLAIN
sasl.mechanism.inter.broker.protocol=PLAIN
#完成身份驗證的類
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
#如果沒有找到ACL（訪問控制列表）配置捅位，則允許任何操作搂抒。
#allow.everyone.if.no.acl.found=true
#需要開啟設置超級管理員, 開啟以下命令
super.users=User:admin
#delete.topic.enable=true
#auto.create.topics.enable=false

config下consumer.properties和producer.properties添加命令

security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN

三 啟動kafka
啟動zookeeper

./bin/zookeeper-server-start.sh config/zookeeper.properties
# 后臺啟動
./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

啟動kafka

./bin/kafka-server-start.sh config/server.properties
# 后臺啟動
./bin/kafka-server-start.sh -daemon config/server.properties

啟動生產(chǎn)者

bin/kafka-console-producer.sh --bootstrap-server 192.168.50.131:9092 --topic test --producer.config config/producer.properties

啟動消費者

bin/kafka-console-consumer.sh --bootstrap-server 192.168.50.131:9092 --topic test --from-beginning --consumer.config config/consumer.properties

四 kafka tool 連接

下載 https://www.kafkatool.com/download.html
用戶名密碼連接
properties

輸入zk地址和端口和kafka版本號，其他隨意

security

Type: SASL Planintext

Advanced

Bootstrap servers: 192.168.x.x:9092
SASL Mechanism: PLAIN

JAAS Config

org.apache.kafka.common.security.plain.PlainLoginModule required
        username="admin"
        password="jowto1234";

顯示字符串信息

# 顯示topic的信息
tools--settings--topics--key/value -- 改為string類型

參考
https://zhuanlan.zhihu.com/p/301343840
http://www.reibang.com/p/806545fc0a28
https://www.kafkatool.com/download.html