Kafka开启SASL用户名密码认证

type

status

date

slug

summary

config目录下创建kafka_server_jaas.conf文件

config目录下创建kafka_client_jaas.conf文件

修改bin目录下kafka_start.sh 在倒数第二行添加kafka_server_jaas.conf的全路径

如下表示为用户yunzai添加topic nginx-log的读写权限。

验证授权

1.以用户yunzai为例，创建JAAS认证文件yunzai_jaas.conf放在config目录下，内容如下:

2.拷贝bin/kafka-console-producer.sh为bin/yunzai-kafka-console-producer.sh，并将JAAS文件作为一个JVM参数传给console producer

倒数第二行添加

3.创建文件producer.config指定如下属性：

4.启动producer

1.以用户yunzai为例，创建JAAS认证文件yunzai_jaas.conf放在config目录下，如果用户跟生产者是同一个，可以复用上面生产者的JAAS文件，内容如下:

2.拷贝bin/kafka-console-consumer.sh为bin/yunzai-kafka-console-consumer.sh，并将JAAS文件作为一个JVM参数传给console consumer 倒数第二行添加

3.创建文件consumer.config指定如下属性：

4.启动consumer

beam设置

OldCamel