鉴权Kafka消费端配置_kafka 命令行发送topic 信息 加鉴权username password

前言

在实际使用Kafka消费的时候我们往往会遇到加密的Kafka集群。
鉴权kafka生产端（SCRAM）

消费者

创建Kafka配置文件

(1)创建 config/client-sasl.properties 文件

cd /app/kafka_2.11-1.1.1

vi config/client-sasl.properties
1
2
3

security.protocol=SASL_PLAINTEXT

sasl.mechanism=SCRAM-SHA-256
1
2
3

(2)根据指定账号创建生产命令( conf文件+sh文件 )

配置config文件指定账号密码:

vi config/kafka_client_jaas_admin.conf
1

KafkaClient {

org.apache.kafka.common.security.scram.ScramLoginModule required

username="admin"

password="admin-secret";

};
1
2
3
4
5
6
7
8
9

这里可以省略

根据指定账号配置消费者命令

创建 config/consumer-admin.properties 文件

vi config/consumer-admin.properties
1

security.protocol=SASL_PLAINTEXT

sasl.mechanism=SCRAM-SHA-256

#group.id=sitech-group
1
2
3
4
5

创建 bin/kafka-console-consumer-admin.sh 文件

cp bin/kafka-console-consumer.sh bin/kafka-console-consumer-admin.sh

vi bin/kafka-console-consumer-admin.sh
1
2
3

#exec $(dirname $0)/kafka-run-class.sh kafka.tools.ConsoleConsumer "$@"

exec $(dirname $0)/kafka-run-class.sh -Djava.security.auth.login.config=$(dirname $0)/../config/kafka_client_jaas_admin.conf kafka.tools.ConsoleConsumer "$@"
1
2
3

使用消费者命令如下:

sh bin/kafka-console-consumer-admin.sh --bootstrap-server ip1:port1,ip2:port2,ip3:port3 --topic flink2KafkaTestSrc --consumer.config ./config/client-sasl.properties
1