Kafka配置SASL/PLAIN认证

1、安装zk，kafka

2、配置server.properties

security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
listeners=SASL_PLAINTEXT://0.0.0.0:9092
advertised.listeners=SASL_PLAINTEXT://host:9092

3、config下配置kafka_server_jaas.conf

KafkaServer {org.apache.kafka.common.security.plain.PlainLoginModule requiredusername="admin"password="admin"user_admin="admin"user_alice="alice";
};

4、在kafka-run-class.sh添加下面配置(其实只需添加KAFKA_SASL_OPTS和$KAFKA_SASL_OPTS部分)

KAFKA_SASL_OPTS='-Djava.security.auth.login.config=/opt/kafka/config/kafka_server_jaas.conf'
# Launch mode
if [ "x$DAEMON_MODE" = "xtrue" ]; thennohup $JAVA $KAFKA_HEAP_OPTS $KAFKA_JVM_PERFORMANCE_OPTS $KAFKA_GC_LOG_OPTS $KAFKA_SASL_OPTS $KAFKA_JMX_OPTS $KAFKA_LOG4J_OPTS -cp $CLASSPATH $KAFKA_OPTS "$@" > "$CONSOLE_OUTPUT_FILE" 2>&1 < /dev/null &
elseexec $JAVA $KAFKA_HEAP_OPTS $KAFKA_JVM_PERFORMANCE_OPTS $KAFKA_GC_LOG_OPTS $KAFKA_SASL_OPTS $KAFKA_JMX_OPTS $KAFKA_LOG4J_OPTS -cp $CLASSPATH $KAFKA_OPTS "$@"
fi

这样，kafka已经开启了SASL/PLAIN权限认证，在这种情况下，producer和consumer是如果不做配置是无法连接kafka的。

如果是用kafka的命令行连接，需要做如下设置:

5、在config目录下创建kafka_client_jaas.conf

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

6、在config下的producer.properties和consumer.properties添加下面配置：

security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN

7、在bin下的kafka-console-producer.sh和kafka-console-consumer.sh下添加下面配置：

if [ "x$KAFKA_OPTS" ]; thenexport KAFKA_OPTS="-Djava.security.auth.login.config=/usr/local/src/kafka_2.10-0.10.1.0/config/kafka_client_jaas.conf"
fi

8、配置完成后，测试下

./bin/kafka-console-producer.sh --broker-list mysql1:9092 --topic test1 --producer.config ./config/producer.properties

./bin/kafka-console-consumer.sh --bootstrap-server mysql1:9092 --topic test1 --consumer.config ./config/consumer.properties

转载于:https://www.cnblogs.com/water-sky/p/10234237.html

Kafka配置SASL/PLAIN认证相关推荐

Kafka—配置SASL/PLAIN认证客户端及常用操作命令
介绍 SASL/PLAIN 是一种简单的 username/password安全认证机制,本文主要总结服务端开启该认证后,命令行客户端进行配置的操作流程. 配置增加jaas.properties ...
go kafka 配置SASL认证及实现SASL PLAIN认证功能
用户认证功能,是一个成熟组件不可或缺的功能.在0.9版本以前kafka是没有用户认证模块的(或者说只有SSL),好在kafka0.9版本以后逐渐发布了多种用户认证功能,弥补了这一缺陷(这里仅介绍SAS ...
kafka SASL认证介绍及自定义SASL PLAIN认证功能
文章目录 kafka 2.x用户认证方式小结 SASL/PLAIN实例(配置及客户端) broker配置客户端配置自定义SASL/PLAIN认证(二次开发) kafka2新的callback接口介 ...
Kafka配置动态SASL_SCRAM认证
Kafka配置动态SASL_SCRAM认证 1.启动Zookeeper和Kafka 2.创建SCRAM证书 3.维护SCRAM证书 3.1查看SCRAM证书 3.1删除SCRAM证书 4.服务端配置 ...
安装 kafka 配置 sasl 认证
一.安装kafka 1.安装jdk yum serach jdk # 查找jdk yum install java-latest-openjdk.x86_64 # 选择jdk安装,这里选择最新的 ...
kafka配置SASL
适用于kafka_2.11-1.1.1版本第1步将kafka_client_jaas.conf/kafka_server_jaas.conf/kafka_zoo_jaas.conf三个文件放入ka ...
Kafka 开启 SASL/PLAINTEXT 认证及 ACL
Linux 安装 Kafka 并开启 SASL/PLAINTEXT 认证前言一.环境准备 1.组件版本 2.下载文件 3.上传文件二.安装 Zookeeper(单节点) 三.安装 Kafka(单 ...
zookeeper和kafka的SASL认证以及生产实践
一.什么是zookeeper? ZooKeeper是一个集中的服务,用于维护配置信息.命名.提供分布式同步以及提供组服务.所有这些类型的服务都以某种形式被分布式应用程序使用.每次它们被实现时,都有大量 ...
KafKa 开启 SASL 验证
项目需要使用kafka的 sasl 权限认证,记录一下kafka的配置. 参考自 Kafka 中文文档注:本文kafka版本是2.1.2,安装目录是 /user/local/kafka2.1.1 . ...

Kafka配置SASL/PLAIN认证

Kafka配置SASL/PLAIN认证相关推荐

最新文章

热门文章