当前位置: 首页 > news >正文

kafka开启Kerberos使用方式

kafka SASL_PLAINTEXT
serviceName 配置: /etc/security/keytabs/kafka.service.keytab 对应的用户名

$ cat /home/sunxy/kafka/jaas25.conf
KafkaClient
{
com.sun.security.auth.module.Krb5LoginModule required
useKeyTab=true
renewTicket=true
serviceName=“ocdp”
keyTab=“/home/sunxy/kafka/kafka.service.keytab”
storeKey=true
useTicketCache=false
principal=“ocdp/wf-gd2-bpit-dp-kafka-17-38@GOERTEK.COM”;
};
Client
{
com.sun.security.auth.module.Krb5LoginModule required
useKeyTab=true
keyTab=“/home/sunxy/kafka/kafka.service.keytab”
storeKey=true
useTicketCache=false
serviceName=“ocdp”
principal=“ocdp/wf-gd2-bpit-dp-kafka-17-38@GOERTEK.COM”;
};

$ cat consumer.properties
security.protocol=SASL_PLAINTEXT
sasl.mechanism=GSSAPI
sasl.kerberos.service.name=ocdp

$ cat producer.properties
security.protocol=SASL_PLAINTEXT
sasl.mechanism=GSSAPI
sasl.kerberos.service.name=ocdp

开启debug: export KAFKA_OPTS=“-Dlog4j.debug=true -Dkafka.logs.dir=/path/to/logs”

export KAFKA_OPTS=“-Djava.security.auth.login.config=/home/sunxy/kafka/jaas25.conf”

/usr/dif/7.1.0-0/kafka/bin/
/opt/cloudera/parcels/CDH-6.3.1-1.cdh6.3.1.p0.1470567/lib/kafka/bin/

/usr/dif/7.1.0-0/kafka/bin/kafka-topics.sh --zookeeper wf-gd2-bpit-dp-nn-17-71:2181,wf-gd2-bpit-dp-nn-17-70:2181,wf-gd2-bpit-dp-nn-17-80:2181 --topic testtopic --replication-factor 3 --partitions 3 --create

/usr/dif/7.1.0-0/kafka/bin/kafka-topics.sh --zookeeper wf-gd2-bpit-dp-nn-17-71:2181,wf-gd2-bpit-dp-nn-17-70:2181,wf-gd2-bpit-dp-nn-17-80:2181 --list

/usr/dif/7.1.0-0/kafka/bin/kafka-console-producer.sh --broker-list 10.11.17.38:6667,10.11.17.39:6667,10.11.17.40:6667 --topic testtopic --producer.config /home/sunxy/kafka/producer.properties

/usr/dif/7.1.0-0/kafka/bin/kafka-console-consumer.sh --topic testtopic --bootstrap-server 10.11.17.38:6667,10.11.17.39:6667,10.11.17.40:6667 --from-beginning --max-messages 100 --consumer.config /home/sunxy/kafka/consumer.properties

http://www.dtcms.com/a/302826.html

相关文章:

  • “本地计算机上的 mysql 服务启动后停止,某些服务在未由其他服务或程序使用时将自动停止”解决方式
  • 算法训练营day34 动态规划② 62.不同路径、63. 不同路径 II、343整数拆分、96.不同的二叉搜索树
  • Kafka 顺序消费实现与优化策略
  • linux diff命令使用教程
  • 最长连续数组
  • 【C++11】列表初始化【{ }使用详解】
  • Facenet(MTCNN+InceptionResnetV1)人脸考勤项目(有缺点,但可用)
  • 境外期货Level2高频Tick历史行情数据获取与应用指南
  • 基于LangGraph Cli的智能数据分析助手
  • MCU 中的 PWM(脉冲宽度调制)是什么?
  • 八大神经网络的区别
  • Java Stream流的使用
  • Open CV图像基本操作可莉版
  • Linux:线程同步与线程互斥
  • PBR技术
  • 杭州网站建设公司,哪家擅长做多语言外贸站?
  • SpringCloude快速入门
  • JVM 笔记:类加载、内存管理、垃圾收集与垃圾收集器
  • binlog与Maxwell 与 慢查询
  • docker排查OOM
  • 图——邻接表基本操作算法实现
  • 【SpringMVC】SpringMVC的概念、创建及相关配置
  • 对比分析 OceanBase 与数据库中间件
  • Java 数学工具类 Math
  • 6、CentOS 9 安装 Docker
  • 香港Web3媒体Techub News活动大事记:时间线全记录
  • 将 NI Ettus USRP X410 的文件系统恢复出厂设置
  • CMake简单教程
  • 智能指挥调度系统:数字化时代的协同决策中枢
  • 从0到1学PHP(一):PHP 基础入门:开启后端开发之旅