kafka-2.12使用记录
kafka-2.12使用记录
安装kafka 2.12版本
下载安装包
根据你的系统下载rpm /deb /zip包等等, 这里我使用的是rpm包
安装命令 rpm -ivh kafka-2.12-1.nfs.x86_64.rpm
启动内置Zookeeper
以下命令要写在同一行上
/opt/kafka-2.12/bin/zookeeper-server-start.sh
/opt/kafka-2.12/config/zookeeper.properties

启动kafka服务器
以下命令要写在同一行上
/opt/kafka-2.12/bin/kafka-server-start.sh
/opt/kafka-2.12/config/server.properties

使用kafka
创建和查看topic
创建一个单 partition分区,单 replication副本 的叫 topic2023 的主题
/opt/kafka-2.12/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic topic2023
查看topic列表
/opt/kafka-2.12/bin/kafka-topics.sh --list --bootstrap-server localhost:9092

创建1个消息生产者
命令输入完后,可以继续输入 多行要发送的消息内容
/opt/kafka-2.12/bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic topic2023

创建1个消息消费者
命令输入完成后回车,可以看到控制台显示出订阅到的消息内容
/opt/kafka-2.12/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic2023 --from-beginning

配置kafka允许外网访问
需要进入config目录,修改server.properties文件里的配置
修改listeners配置项
listeners指定kafka监听的本地地址和端口,这里配置为0.0.0.0:9092表示监听所有网络接口
listeners = PLAINTEXT://0.0.0.0:9092
修改advertised.listeners配置项
advertised.listeners是用于向客户端公布你的kafka访问地址,需要配置为你的机器的外部IP和端口
advertised.listeners=PLAINTEXT://10.1.5.212:9092

测试zookeeper联通性
可以使用prettyZoo客户端工具测试访问zk服务器

使用kafkaUI-lite在线浏览和测试kafka
什么是kafkaUI-lite
kafka-ui-lite是一个开源的kafka监控项目,可以在gitee下载.
提供了对kafka 、zookeeper 、redis的监控和管理功能,
支持在线浏览和管理kafka的 topic主题/kafka集群/group分组
支持在线发送kafka消息
使用kafkaUI-lite查看topic

使用kafkaUI-lite创建topic

使用kafkaUI-lite发送消息

使用kafkaUI-lite查看zookeeper信息

相关文章:
kafka-2.12使用记录
kafka-2.12使用记录 安装kafka 2.12版本 下载安装包 根据你的系统下载rpm /deb /zip包等等, 这里我使用的是rpm包 安装命令 rpm -ivh kafka-2.12-1.nfs.x86_64.rpm启动内置Zookeeper 以下命令要写在同一行上 /opt/kafka-2.12/bin/zookeeper-server-start.sh /opt/kafka-2…...
C++笔记之将定时器加入向量并设置定时器的ID为i
C笔记之将定时器加入向量并设置定时器的ID为i code review! 文章目录 C笔记之将定时器加入向量并设置定时器的ID为i关于代码中的void operator()() 运行 代码 #include <chrono> #include <iostream> #include <thread> #include <vector>// 定义定时…...
将一组元素四舍五入到指定精度(小数位数)numpy.around()
【小白从小学Python、C、Java】 【计算机等级考试500强双证书】 【Python-数据分析】 将一组元素四舍五入 到指定精度(小数位数) numpy.around() [太阳]选择题 关于以下代码说法错误的一项是? import numpy as np anp.array([21.3,9.67,8.5, -1.13, -2.67]) print(【显示】a为…...
tinyint这个值在MySQL中的值有哪些
在MySQL中,TINYINT是一种整数数据类型,用于存储小范围的整数值。它占用1个字节的存储空间,可以表示的值范围是从-128到127(有符号)或者从0到255(无符号)。 以下是在MySQL中使用TINYINT数据类型…...
JVM 内存结构
1、方法区(线程共享) 存储静态变量(静态方法、变量、代码块)、常量池、类信息 2、堆信息(线程共享) 存储实例对象,例如 new 出来的对象信息 A a1 new A() 3、虚拟机栈(线程隔离) 每个线程的都有…...
基于百度语音识别API智能语音识别和字幕推荐系统——深度学习算法应用(含全部工程源码)+测试数据集
目录 前言总体设计系统整体结构图系统流程图 运行环境模块实现1. 数据预处理2. 翻译3. 格式转换4. 音频切割5. 语音识别6. 文本切割7. main函数 系统测试工程源代码下载其它资料下载 前言 本项目基于百度语音识别API,结合了语音识别、视频转换音频识别以及语句停顿…...
数字万用表测量基础知识--使用DMM测量电流
概览 DMM(即数字万用表)是一种电气测试和测量仪器,可测量直流和交流信号的电压、电流和电阻。本文介绍如何正确使用和理解数字万用表(DMM)。 使用DMM测量电流 另一个常见的测量功能是直流和交流电流测量。电压是通过与电路并联进行测量&am…...
【BASH】回顾与知识点梳理(二十)
【BASH】回顾与知识点梳理 二十 二十. 十六至十九章知识点总结及练习20.1 总结20.2 练习 该系列目录 --> 【BASH】回顾与知识点梳理(目录) 二十. 十六至十九章知识点总结及练习 20.1 总结 shell script 是利用 shell 的功能所写的一个『程序 (prog…...
Arduino驱动SGP40空气质量传感器(气体传感器篇)
目录 1、传感器特性 2、硬件原理图 3、控制器和传感器连线图 4、驱动程序 SGP40空气质量传感器是业内知名的瑞士公司Sensirion推出的新一代SGP40数字VOC传感器芯片。基于Sensirion的CMOSens技术,SGP40在单个芯片上提供了完整的传感器系统,包括温控微加热板和室内空气质量…...
识别和应对内存抖动
关于作者:CSDN内容合伙人、技术专家, 从零开始做日活千万级APP。 专注于分享各领域原创系列文章 ,擅长java后端、移动开发、人工智能等,希望大家多多支持。 目录 一、导读二、概览三、案例分析3.1 使用memory-profiler3.2 使用 cp…...
3.3用于共享数据保护的替代工具
用于共享数据保护的替代工具 虽然互斥元是最通用的机制,但提到保护共享数据时,它们并不是唯一的选择;还有别的替代品,可以在特定情况下提供更恰当的保护。 一个特别极端(但却相当常见)的情况,…...
探索数据之美:初步学习 Python 柱状图绘制
文章目录 一 基础柱状图1.1 创建简单柱状图1.2 反转x和y轴1.3 数值标签在右侧1.4 演示结果 二 基础时间线柱状图2.1 创建时间线2.2 时间线主题设置取值表2.3 演示结果 三 GDP动态柱状图绘制3.1 需求分析3.2 数据文件内容3.3 列表排序方法3.4 参考代码3.5 运行结果 一 基础柱状图…...
647. 回文子串
boolean默认类型是false class Solution {public int countSubstrings(String s) {if(s null) return 0;int result 0;int length s.length();boolean[][] dp new boolean[length][length];for(int j0;j<length;j){for(int i0;i<j;i){if(s.charAt(i) s.charAt(j)){i…...
cmake (更新中)
概述 关于 CMake CMake 是一个可扩展的开源系统,以一种与操作系统和编译器无关的方式来管理构建过程。与许多跨平台系统不同,CMake 被设计为与本机构建环境配合使用。在每个源代码目录中放置简单的配置文件(称为 CMakeLists.txt 文件…...
【go语言基础】指针数组和数组指针
1.概念 (1)指针数组: 存储指针的数组,也叫存储地址的数组,简单说就是存储地址的。 首先它是一个数组,数组中的元素都是指针(地址)。 (2)数组指针…...
ModaHub魔搭社区——Milvus Cloud向量数据库
向量数据库:在AI时代的快速发展与应用 摘要: 随着人工智能技术的不断进步,向量数据库在处理大规模数据方面发挥着越来越重要的作用。本文介绍了向量数据库的基本概念、应用场景和技术挑战,并详细阐述了Milvus Cloud作为典型的向量数据库产品的技术特点、性能优化和应用案例…...
【Java】常用Stream API
常见 Stream 流表达式 总体结构图 一、两大类型 中间操作(Intermediate Operations) 中间操作是指在Stream上执行的操作, 它们返回一个新的Stream, 允许你链式地进行多个中间操作. 终端操作(Terminal Operations) 对Stream进行最终处理的操作, 当调用终端操作时, Stream会开始执…...
P1941 [NOIP2014 提高组] 飞扬的小鸟
代码部分前有一千六百字了 P1941 [NOIP2014 提高组] 飞扬的小鸟 考察对背包 dp 算法过程理解的透彻性。过程透彻性也是解决所有问题的关键(建立在算法已学的基础上)。 n , m n,m n,m 的范围足够我们 O ( n m ) O(nm) O(nm) 的遍历整个地图。设 f i , …...
Vue3+Element plus+pageHelper实现分页
安装element plus npm install element-plus --save引入 修改main.js: import { createApp } from vue import App from ./App.vue import ElementPlus from element-plus import element-plus/dist/index.cssconst app createApp(App) app.use(ElementPlus) ap…...
外贸路上那些哭笑不得的事情
前几天一个老顾客在软件上联系,说自己上次的订货体验很满意,货物的质量很好,而且服务和回复也很及时, 比起他之前的供货商要好很多,他之前的供货商虽然货物的质量也很好,但是每次询问问题都是要等好久才给…...
手把手教你用Vivado为Microblaze软核搭建Linux最小系统(含DDR3、UART、以太网配置)
从零构建Microblaze软核Linux硬件系统:Vivado实战指南 在FPGA上运行Linux系统一直是嵌入式开发者的进阶挑战,而Xilinx的Microblaze软核处理器为这一目标提供了灵活高效的解决方案。不同于传统ARM架构的固定硬件,Microblaze允许开发者根据项目…...
「码动四季·开源同行」go实战案例:如何使用 Prometheus 和 Grafana 监控预警服务集群?
监控和预警平台是互联网公司较为重要的后端架构组成之一,是整个运维乃至整个产品生命周期中最重要的一环,它能够事前及时预警发现故障,事后提供详实的数据用于追查定位问题。Prometheus和Grafana 相结合是开源服务监控和预警平台的主流方案之…...
OpenClaw多模态开发:千问3.5-27B视觉API调用与结果解析
OpenClaw多模态开发:千问3.5-27B视觉API调用与结果解析 1. 为什么选择OpenClaw对接多模态模型 去年我在整理个人照片库时,发现手动标注几千张旅行照片几乎是不可能完成的任务。直到偶然接触到OpenClaw和千问3.5-27B的组合,才找到自动化解决…...
OpenClaw多通道管理:千问3.5-9B同时服务飞书与钉钉机器人
OpenClaw多通道管理:千问3.5-9B同时服务飞书与钉钉机器人 1. 为什么需要多通道管理? 去年我接手了一个跨部门协作项目,团队同时使用飞书和钉钉两种沟通工具。每次需要查询数据或生成报告时,成员们要么在飞书群里我,要…...
OpenClaw多通道接入:Qwen3-4B同时服务飞书与钉钉机器人
OpenClaw多通道接入:Qwen3-4B同时服务飞书与钉钉机器人 1. 为什么需要多通道接入? 上周我遇到一个尴尬场景:团队部分成员用飞书沟通,另一些用钉钉。当我尝试用OpenClaw搭建自动化助手时,发现默认配置只能对接单一平台…...
别再只用DWA了!ROS Melodic下TEB、DWB等5种局部规划器保姆级配置与实战对比
别再只用DWA了!ROS Melodic下5种局部规划器深度评测与工程实践指南 差速驱动机器人在仓库货架间穿梭时突然"卡死",在狭窄走廊中频繁出现路径震荡,遇到动态行人时避障反应迟钝——这些场景是否让你反复调整DWA参数到怀疑人生&#x…...
日期时间数据的运算
下面内容摘录自《用R探索医药数据科学》专栏文章的部分内容(原文6364字)。 2篇2章16节:R 语言中日期时间数据的关键处理要点_r语言从数字转为日期-CSDN博客 3、日期时间数据的运算 日期时间运算在分析中非常常见。R中的日期时间运算非常直观…...
Git常用命令速查手册,微硕WST8205A双N沟MOSFET,汽车阅读灯静音负载开关。
常用的 Git 命令指南 Git 是当今最流行的分布式版本控制系统,广泛应用于软件开发中。掌握常用 Git 命令可以显著提高开发效率。以下是 Git 日常操作中频繁使用的命令及其用途。 初始化与克隆仓库 git init 在当前目录创建一个新的 Git 仓库,生成隐藏的 .…...
stock-sdk-mcp 的实践整理侗
一、什么是urllib3? urllib3 是一个用于处理 HTTP 请求和连接池的强大、用户友好的 Python 库。 它可以帮助你: 发送各种 HTTP 请求(GET, POST, PUT, DELETE等)。 管理连接池,提高网络请求效率。 处理重试和重定向。 支…...
EnOcean BLE设备轻量级解析库设计与实现
1. 项目概述EnOceanBleDevices 是一个面向嵌入式平台的轻量级 BLE 协议栈扩展库,专为集成 EnOcean 自供电 BLE 设备而设计。其核心目标并非替代标准 BLE 协议栈(如 ESP-IDF 的 NimBLE 或 Bluedroid),而是构建在底层 BLE 扫描能力之…...
