kafka在linux环境下的执行命令

#创建topic 
/data/app/kafka/bin/kafka-topics.sh --create  --bootstrap-server  127.0.0.1:8318 --replication-factor 1 --partitions 12 --topic yunpei-track --command-config /data/app/kafka/config/admin.conf

#新增用户,新建用户mytest
/data/app/kafka/bin/kafka-configs.sh  --zookeeper 127.0.0.1:8325 --alter --add-config 'SCRAM-SHA-512=[password=ztd123]' --entity-type users --entity-name ztdadmin

#更新用户,更新mytest的密码为mytest
/data/app/kafka/bin/kafka-configs.sh --zookeeper 192.168.18.11:12181 --alter --add-config 'SCRAM-SHA-512=[password=zto419#Pw62]' --entity-type users --entity-name mytest

#读取权限,设置用户mytest的消费者权限
/data/app/kafka/bin/kafka-acls.sh --authorizer-properties zookeeper.connect=127.0.0.1:8325 --add --allow-principal User:"yunpeiread" --consumer --topic 'yunpei-track' --group '*'

#写入权限,设置用户mytest的生产者权限
/data/app/kafka/bin/kafka-acls.sh --authorizer-properties zookeeper.connect=127.0.0.1:8325 --add --allow-principal User:"ztdadmin" --producer --topic 'yunpei-track' --group '*'

#查看所有分组
bin/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:8318 --list --command-config /data/app/kafka/config/admin.conf

#查看指定分组的消费情况
./bin/kafka-consumer-groups.sh --describe --bootstrap-server 127.0.0.1:8318 --group bigdata1  --command-config /data/app/kafka/config/admin.conf

#查看所有用户权限情况
/data/app/kafka/bin/kafka-acls.sh --authorizer-properties zookeeper.connect=127.0.0.1:8325 --list

#查看所有主题
/data/app/kafka/bin/kafka-topics.sh --list --zookeeper 127.0.0.1:8325

/data/app/kafka/bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:8318 --topic test_order_tag_r2p5 --group order_tag_group_test

1、查询topic，进入kafka目录：
/data/app/kafka/bin/kafka-topics.sh --list --zookeeper 127.0.0.1:8325
 
2、查询topic内容：
/data/app/kafka/bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:8318 --topic bignet-order-test --from-beginning
 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/720971.shtml

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

相关文章

uniapp实现进度条组件

uniapp实现进度条组件

首先&#xff0c;在uniapp项目中创建一个自定义组件&#xff0c;可以命名为Progress.vue。在Progress.vue中&#xff0c;编写如下代码&#xff1a; <template><view class"progress"><view class"progress-bar" :style"{width: progr…
阅读更多...
缓存淘汰策略看完这篇就够了

缓存淘汰策略看完这篇就够了

LFU 缓存淘汰算法 LFU 是 Least Frequently Used 的缩写&#xff0c;即 最少使用 缓存淘汰算法。LFU算法根据数据项在缓存中的访问频率来决定淘汰哪些数据项。访问频率越高 的数据项被认为是更重要的&#xff0c;访问频率越低 的数据项被认为是更不重要的。 LFU算法的具体工作原…
阅读更多...
c# 查询dataset数据集

c# 查询dataset数据集

1、读取xml&#xff0c;见上一个博客 2、加载到dataset中&#xff0c;按照条件进行dataset数据集查询后返回满足条件结果 public static string GetStrByID(string ID) { string str string.Empty; DataSet ds FromXmlFileToDataSet(); Dat…
阅读更多...
HarmonyOS4开发 数据持久化-用户首选项 封装

HarmonyOS4开发 数据持久化-用户首选项 封装

import preferences from ohos.data.preferences;class PreferencesUtil {prefMap: Map<string, preferences.Preferences> new Map()async loadPreference(context, name: string) {try { //加载preferencesconst pref await preferences.getPreferences(context, nam…
阅读更多...
Kali Linux 2024.1

Kali Linux 2024.1

Kali Linux 2024.1刚刚发布&#xff0c;标志着这个备受欢迎的安全重点Linux发行版在今年的首次重大更新。以其先进的渗透测试和安全审计功能而闻名&#xff0c;它是安全专业人员和爱好者的首选工具。 Kali 2024.1 亮点 本次发布由 Linux 内核 6.6 提供支持&#xff0c;突出了…
阅读更多...
C语言qsort函数介绍

C语言qsort函数介绍

前言 学到了函数指针&#xff0c;那这篇博客我们可以根据函数指针&#xff0c;了解一个函数qsort的应用与模拟实现 欢迎关注个人主页&#xff1a;小张同学zkf 若有疑问 评论区见 目录 1.回调函数 2.qsort函数使用 3.qsort模拟实现 1.回调函数 讲这个东西之前我们来认识一下…
阅读更多...
mq基础类设计

mq基础类设计

消息队列就是把阻塞队列这样的数据结构单独提取成一个程序独立进行部署。——>实现生产者消费者模型。 但是阻塞队列是在一个进程内部进行的&#xff1b; 消息队列是在进程与进程之间进行实现的&#xff0c; 解耦合&#xff1a;就是在分布式系统中&#xff0c;A服务器调用B…
阅读更多...
Tomcat -2

Tomcat -2

① 单机反向代理 7-2 代理服务器 7-5 tomcat 设置 7-3 测试&#xff1a; 代理服务器那里写什么就显示什么 ② 多机反向代理 实现动静分离和负载均衡 7-2 nginx 7-3 7-5 测试&#xff1a; 看静态&#xff1a; 看动态&#xff1a; ③ 反向代理多机多级 7-2 7-1 和 7-4 7-3…
阅读更多...
LeetCode45：搜索插入位置

LeetCode45：搜索插入位置

问题描述 给定一个排序数组和一个目标值&#xff0c;在数组中找到目标值&#xff0c;并返回其索引。如果目标值不存在于数组中&#xff0c;返回它将会被按顺序插入的位置。 请必须使用时间复杂度为 O(log n) 的算法。 示例 1: 输入: nums [1,3,5,6], target 5 输出: 2 示例…
阅读更多...
【STM32】STM32学习笔记-读写内部FLASH 读取芯片ID(49)

【STM32】STM32学习笔记-读写内部FLASH 读取芯片ID(49)

00. 目录 文章目录 00. 目录01. FLASH概述02. 读写内部FLASH接线图03. 读写内部FLASH相关API04. 读写内部FLASH程序示例05. 读写芯片ID接线图06. 读写芯片ID程序示例07. 程序示例下载08. 附录 01. FLASH概述 STM32F10xxx内嵌的闪存存储器可以用于在线编程(ICP)或在程序中编程(…
阅读更多...
华为OD机试 - 数字排列 - 深度优先搜索dfs算法（Java 2024 C卷 100分）

华为OD机试 - 数字排列 - 深度优先搜索dfs算法（Java 2024 C卷 100分）

目录 专栏导读一、题目描述二、输入描述三、输出描述1、输入2、输出3、说明 四、解题思路五、Java算法源码六、效果展示1、输入2、输出3、说明 华为OD机试 2024C卷题库疯狂收录中&#xff0c;刷题点这里 专栏导读 本专栏收录于《华为OD机试&#xff08;JAVA&#xff09;真题&a…
阅读更多...
前端：js实现页面跳转

前端：js实现页面跳转

一、使用 window.location 对象来实现页面跳转 // 在当前页面打开新的 URL window.location.href https://www.example.com;// 或者使用下面的方法 window.location.assign(https://www.example.com); 二、在当前页面的历史记录中创建一个新的条目&#xff08;允许用户通过浏…
阅读更多...
外部存储器接口（EMIF）

外部存储器接口（EMIF）

外部存储器接口&#xff08;EMIF&#xff09; 该设备支持双核架构&#xff1b;为了为每个CPU子系统提供一个专用的EMIF&#xff0c;该设备支持两个EMIF模块——EMIF1和EMIF2。两个模块完全相同&#xff0c;具有相同的功能集&#xff0c;但具有不同的地址/数据大小。EMIF1在CPU…
阅读更多...
Unity 角色控制(初版)

Unity 角色控制(初版)

角色控制器组件&#xff0c;当然是将组件放在角色上了。 using System.Collections; using System.Collections.Generic; using UnityEngine;public class c1 : MonoBehaviour {// 获取角色控制器private CharacterController player;void Start(){// 加载角色控制器player …
阅读更多...
Qt应用软件【测试篇】Dr.Memory动态测试内存

Qt应用软件【测试篇】Dr.Memory动态测试内存

文章目录 Dr.Memeory 简介特点下载地址windows安装及使用Dr. Memory在Linux或Mac OSX在Windows上安装Dr. MemoryDr. Memory和MinGWDr. Memory和Visual Studio使用Visual Studio编译没有Visual Studio集成开发环境（IDE）命令测试结果更多内容
阅读更多...
机器学习 | 模型性能评估

机器学习 | 模型性能评估

目录 一. 回归模型的性能评估1. 平均平方误差(MSE)2. 平均绝对误差(MAE)3. R 2 R^{2} R2 值3.1 R 2 R^{2} R2优点 二. 分类模型的性能评估1. 准确率&#xff08;Accuracy&#xff09;2. 召回率&#xff08;Recall&#xff09;3. 精确率&#xff08;Precision&#xff09;4. …
阅读更多...
大模型学习笔记五：RAG

大模型学习笔记五：RAG

文章目录 一、RAG介绍1）局限性2）通过检索增强生成二、RAG系统的基本搭建流程1）搭建流程简介2）文档的加载和切割3）检索引擎4）LLM接口封装5）prompt模板6）RAG Pipeline初探7）关键字检索局限性三、向量检索1）文本向量2）向量相似度计算3）向量数据库4）基于向量检索的RAG…
阅读更多...
电源完整性设计的重要三步！

电源完整性设计的重要三步！

电源模块布局布线 电源模块是电子设备的能量来源&#xff0c;其性能与布局直接影响到整个系统的稳定性和效率。正确的布局和走线不仅能减少噪声干扰&#xff0c;还能确保电流的顺畅流通&#xff0c;从而提高整体性能。 1、电源模块布局 ● 源头处理&#xff1a;电源模块作为…
阅读更多...
Java 面试题

Java 面试题

Java 基础 以下代码执行结果&#xff1f; 示例1&#xff1a; public static void main(String[] args) {int a 0;Integer b 0;String c "0";String d new String("0");change(a, b, c, d);System.out.println(a "|" b "|" …
阅读更多...
网络支付个人信息安全的挑战与保护策略

网络支付个人信息安全的挑战与保护策略

随着互联网的飞速发展和大数据时代的来临&#xff0c;网络支付已逐渐成为人们日常生活中不可或缺的一部分。从线上购物到线下扫码&#xff0c;从水电煤缴费到交通出行&#xff0c;网络支付已经渗透到生活的方方面面。然而&#xff0c;在享受便捷的同时&#xff0c;网络支付个人…
阅读更多...
最新文章

Copyright @ 2022~2023