测试kafka权限验证

测试

  1. 新建topic
cd sasl_kafka_tools
#topic:test-sasl 分区数:2 副本数:1
./kafka-topic-create.sh test-sasl 2 1
  1. 生产数据脚本
cd sasl_kafka_tools
#topic:test-sasl 发送数据总量:100000 每秒发送数据量:1
./kafka-perf-test.sh test-sasl 100000 1
  1. 二级kafka创建topic ./kafka-topic-create.sh test-sasl-1 2 2
  2. 配置kafka-mirror-maker配置信息
vim ENV_KAFKA_HOST
# mirror_maker配置，添加白名单及映射关系
MIRROR_WHITE_LIST="teset-copy|test-sasl"
MIRROR_HANGER_ARGS="teset-copy->copy1,copy2,copy3,copy4,copy5,copy6,copy7,copy8,copy9,copy10|test-sasl->test-sasl-1"
  1. 查看mirror-maker状态 ./pstatus.sh mk
  2. 重启mirror-maker ./prestart.sh mk
  3. 在二级kafka执行消费脚本，查看到数据已经同步 ./kafka-consumer.sh test-sasl-1
  4. 添加新用户 ./kafka-sasl-user-alter.sh sasl saslpwd
  5. 添加读权限 ./kafka-sasl-topic-add-token.sh sasl test-sasl-1 r
  6. 添加写权限 ./kafka-sasl-topic-add-token.sh sasl test-sasl-1 w
  7. 程序验证
  8. 删除写权限 ./kafka-sasl-topic-remove-token.sh sasl test-sasl-1 w
  9. 删除读权限 ./kafka-sasl-topic-remove-token.sh sasl test-sasl-1 r