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.pswp.cn/web/90987.shtml
繁体地址,请注明出处:http://hk.pswp.cn/web/90987.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Unity教程(二十四)技能系统 投剑技能(中)技能变种实现

Unity开发2D类银河恶魔城游戏学习笔记 Unity开发2D类银河恶魔城游戏学习笔记目录 技能系统 Unity教程(二十一)技能系统 基础部分 Unity教程(二十二)技能系统 分身技能 Unity教程(二十三)技能系统 掷剑技能…

局域网TCP通过组播放地址rtp推流和拉流实现实时喊话

应用场景,安卓端局域网不用ip通过组播放地址实现实时对讲功能发送端: ffmpeg -f alsa -i hw:1 -acodec aac -ab 64k -ac 2 -ar 16000 -frtp -sdp file stream.sdp rtp://224.0.0.1:14556接收端: ffmpeg -protocol whitelist file,udp,rtp -i stream.sdp -acodec pcm…

基于深度学习的医学图像分析:使用YOLOv5实现细胞检测

最近研学过程中发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击链接跳转到网站人工智能及编程语言学习教程。读者们可以通过里面的文章详细了解一下人工智能及其编程等教程和学习方法。下面开始对正文内容的…

32.768KHZ 3215晶振CM315D与NX3215SA应用全场景

在现代电子设备中,一粒米大小的晶振,却是掌控时间精度的“心脏”。CITIZEN的CM315D系列与NDK的NX3215SA系列晶振便是其中的佼佼者,它们以 3.2 1.5 mm 的小尺寸”(厚度不足1mm),成为智能设备中隐形的节奏大师。精准计时的奥秘这两…

嵌软面试——ARM Cortex-M寄存器组

Cortex-M内存架构包含16个通用寄存器,其中R0-R12是13个32位的通用寄存器,另外三个寄存器是特殊用途,分别是R13(栈指针),R14(链接寄存器),R15(程序计数器)。对于处理器来说…

7.DRF 过滤、排序、分页

过滤Filtering 对于列表数据可能需要根据字段进行过滤,我们可以通过添加django-fitlter扩展来增强支持。 pip install django-filter在配置文件中增加过滤器类的全局设置: """drf配置信息必须全部写在REST_FRAMEWORK配置项中""…

二、CUDA、Pytorch与依赖的工具包

CUDA Compute Unified Device Architecture(统一计算架构)。专门用于 GPU 通用计算 的平台 编程接口。CUDA可以使你的程序(比如矩阵、神经网络)由 GPU 执行,这比CPU能快几十甚至上百倍。 PyTorch 是一个深度学习框架…

SpringCloude快速入门

近期简单了解一下SpringCloude微服务,本文主要就是我学习中所记录的笔记,然后具体原理可能等以后再来深究,本文可能有些地方用词不专业还望包容一下,感兴趣可以参考官方文档来深入学习一下微服务,然后我的下一步学习就是docker和linux了。 nacos: Nacos 快速开始 | Nacos 官网…

GPT Agent与Comet AI Aent浏览器对比横评

1. 架构设计差异GPT Agent的双浏览器架构:文本浏览器:专门用于高效处理大量文本内容,适合深度信息检索和文献追踪,相当于Deep Research的延续可视化浏览器:具备界面识别与交互能力,可以点击网页按钮、识别图…

应用信息更新至1.18.0

增加DO权限 增加权限管理(需DO支持) 增加应用冻结隐藏(需DO支持) 增加权限委托(需DO支持) 增加特殊组件 ...

常用git命令集锦

git init 初始化 将当前目录初始化为 git 本地仓库,此时会在本地创建一个 .git 的文件夹 git init -q 静默执行,就是在后台执行 git init --bare –bare 参数,一般用来初始化一个空的目录,作为远程存储仓库 git init --template dir –templa…

skywalking安装

一、简介 SkyWalking是一款用于分布式系统跟踪和性能监控的开源工具。它可以帮助开发人员了解分布式系统中不同组件之间的调用关系和性能指标,从而进行故障排查和性能优化。 它支持多种语言和框架,包括Java、.NET、Node.js等。它通过在应用程序中插入代…

利用DataStream和TrafficPeak实现大数据可观察性

可观察性工作流对于深入了解应用程序的健康状况、客户流量和整体性能至关重要。然而,要实现真正的可观察性还面临一些挑战,包括海量的流量数据、数据保留、实施时间以及各项成本等。TrafficPeak是一款为Akamai云平台打造,简单易用、可快速部署…

jQuery 最新语法大全详解(2025版)

引言 jQuery 作为轻量级 JavaScript 库,核心价值在于 简化 DOM 操作、跨浏览器兼容性和高效开发。尽管现代框架崛起,jQuery 仍在遗留系统维护、快速原型开发中广泛应用。本文涵盖 jQuery 3.6 核心语法,重点解析高效用法与最佳实践。 一、jQu…

Android 15 修改截图默认音量大小

概述 在 Android 15 中,截图音效的默认音量可能过大,影响用户体验。本文将介绍如何通过修改系统源码来调整截图音效的默认音量大小。 修改位置 需要修改的文件路径: frameworks/base/packages/SystemUI/src/com/android/systemui/screenshot/ScreenshotSoundProvider.kt…

Python爬虫实战:快速采集教育政策数据(附官网工具库API)

解锁教育政策研究的数据金矿,用技术提升学术效率 在教育政策研究领域,获取最新、最全面的政策文本是学术工作的基础。传统手动收集方式效率低下且容易遗漏关键政策,而Python爬虫技术为教育研究者提供了高效的数据采集解决方案。本文将系统介…

验证回文串-leetcode

如果在将所有大写字符转换为小写字符、并移除所有非字母数字字符之后,短语正着读和反着读都一样。则可以认为该短语是一个 回文串 。 字母和数字都属于字母数字字符。 给你一个字符串 s,如果它是 回文串 ,返回 true ;否则&#xf…

嵌入式学习日志(十)

10 学习指针1 指针核心定义与本质1.1 指针与指针变量1、指针即地址,指针变量是存放地址的变量,其大小与操作系统位数相关:64 位系统中占 8 字节,32 位系统中占 4 字节。2、指针的核心功能是通过地址间接访问目标变量&#xff0…

Anaconda创建环境报错:CondaHTTPEFTOT: HTTP 403 FORBIDDEN for url

一、快速解决方案这类报错的原因通常是由于 conda 无法访问镜像源或权限被服务器拒绝,以下是常见原因和对应的解决方案:检查镜像源拼写是否正确conda config --show channels清华源镜像示例如果不正确,先清除旧配置del %USERPROFILE%\.condar…

亚马逊地址关联暴雷:新算法下的账号安全保卫战

2025年Q3,上千个店铺因共享税代地址、海外仓信息重叠等问题被批量冻结,为行业敲响了“精细化合规”的警钟。事件复盘:地址成为关联风控的“致命开关”税代机构违规引发“多米诺效应”事件的导火索指向税代机构“saqibil”,其为降低…