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

Kafka基本使用

news 2026/2/9 17:00:18

查看Kafka的进程是否在运行

#命令行终端中运行如下命令
ps -ef | grep kafka


find / -iname  kafka-server-start.shcd /usr/local/kafka/bin/#启动kafka
./kafka-server-start.sh  -daemon   /usr/local/kafka/config/server.properties

 Kafka默认使用9092端口提供服务，可以使用以下命令查看该端口是否已经打开

netstat -tnlp | grep 9092

 或者jps

如果Kafka进程正在运行，则会出现一个类似于以下的输出：

 

 

 
 

2705是kafka进程 
 

 

 zookeeper 配置
 

 find / -iname zoo.cfgcd /usr/local/zookeeper/conf

 

 

kafka 配置
 

 

 find / -iname server.propertiescd /usr/local/kafka/config/
 

 

待更新
 

 
 

 

 

  启动zookeeper
 

find / -iname  zkServer.shcd /usr/local/zookeeper/bin/#修改配置重新启动
/zkServer.sh restart
 

 
 

 

 

 查看 zookeeper 是否正常启动成功
 

sudo netstat -tulnp | grep 2181

 

 

 

查看Kafka日志
 

 

tail /usr/local/kafka/logs/server.log

 

 

 
 

 

 

 

测试Kafka服务
 

可以通过在命令行终端中执行一些Kafka命令来测试Kafka服务是否正常工作。例如，可以使用以下命令查看Kafka当前可用的主题列表：
 

/usr/local/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --list

 

 

 
 

启动生产者
 

 ./kafka-console-producer.sh --broker-list localhost:9092 --topic helloKafka

 

 

 启动消费者
 

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic helloKafka

 

 

kafka可视化工具Kafka
 

 

 

 

 

 















相关文章：
















Kafka基本使用




查看Kafka的进程是否在运行 
#命令行终端中运行如下命令
ps -ef | grep kafkafind / -iname  kafka-server-start.shcd /usr/local/kafka/bin/#启动kafka
./kafka-server-start.sh  -daemon   /usr/local/kafka/config/server.propertiesKafka默认使用9092端口提供服务&#xf…...






编程日记
2023/8/27 2:07:30



















【目标检测】理论篇（2）YOLOv3网络构架及其代码实现




网络构架图： 代码实现： 
import math
from collections import OrderedDictimport torch.nn as nn#---------------------------------------------------------------------#
#   残差结构
#   利用一个1x1卷积下降通道数，然后利用一个3x3卷…...






编程日记
2023/8/27 2:06:30



















k8s之工作负载、Deployment、DaemonSet、StatefulSet、Job、CronJob及GC




文章目录 1、工作负载1.1、定义1.2、分类 2、Deployment2.1、定义2.2、Deployment创建2.3、Deployment 更新机制2.3.1、比例缩放（Proportional Scaling）2.3.2、HPA（动态扩缩容）2.3.2.1、需要先安装metrics-server2.3.2.2、配置hpa…...






编程日记
2023/8/27 2:05:29



















IDEA项目实践——Element UI概述




系列文章目录 
IDEA项目实践——JavaWeb简介以及Servlet编程实战 
IDEA项目实践——Spring当中的切面AOP 
IDEA项目实践——Spring框架简介，以及IOC注解 
IDEA项目实践——动态SQL、关系映射、注解开发 
IDEWA项目实践——mybatis的一些基本原理以及案例 
文章目录 …...






编程日记
2023/8/27 2:04:28



















Docker 容器学习笔记




Docker 容器学习笔记 
容器的由来 
早先，虚拟机通过操作系统实现相互隔离，保证应用程序在运行时相互独立，避免相互干扰。但是操作系统又笨又重，耗费资源严重： 容器技术只隔离应用程序的运行时环境但容器之间共享同一个…...






编程日记
2023/8/27 2:03:27



















Day03-vue基础




Day03-vue基础 
一 列表渲染 
v-for这个指令可以实现列表渲染 
1 数组 <ul><!-- v-for遍历的时候,key必须赋唯一值第一个参数是数组元素,第二个参数是元素下标--><li v-for="(item,index) in [1,3,5,7]" :key="item">{{item}}--{{index}…...






编程日记
2023/8/27 2:02:25



















RAC sid=‘*‘ 最好加上 v$system_parameter




实验结论&#xff1a;在RAC环境中&#xff0c;最好修改参数sid* 安全可靠&#xff0c;因为暂时未明确知道哪些参数是默认全局修改&#xff0c;什么参数是默认单节点修改的&#xff0c;* 靠谱&#xff0c;不容易出问题 在RAC环境中&#xff0c;修改全局参数scopespfile生效时&am…...






编程日记
2023/8/27 2:01:24



















【位运算进阶之----左移（＜＜）】




今天我们来谈谈左移这件事。 
❤️简单来说&#xff0c;对一个数左移就是在其的二进制表达末尾添0。左移一位添一个0&#xff0c;结果就是乘以2&#xff1b;左移两位添两个0&#xff0c;结果就乘以2 ^ 2&#xff1b;左移n位添n个0&#xff0c;结果就是乘以2 ^ n&#xff0c;小心…...






编程日记
2023/8/27 2:00:22



















石油石化行业网络监控运维方案，全局态势感知，实时预警




石油石化行业是一个高科技密集型行业&#xff0c;投资巨大、人员众多&#xff0c;各产业价值链的关联度较高&#xff0c;大型石油石化企业实现了上中下游产业的一体化协同发展。随着工业4.0时代的来临&#xff0c;信息化和工业化融合&#xff0c;物联网、云计算等新技术的普及推…...






编程日记
2023/8/27 1:59:21



















MyBatis 的关联关系配置 一对多，一对一，多对多 关系的映射处理




目录 
一.关联关系配置的好处 二. 导入数据库表&#xff1a; 三.    一对多关系&#xff1a;--    一个订单对应多个订单项        
四.一对一关系&#xff1a;---一个订单项对应一个订单 
五.多对多关系&#xff08;两个一对多&#xff09; 一.关联关系配置的好处 MyBatis是一…...






编程日记
2023/8/27 1:58:20



















Diffusion Models for Image Restoration and Enhancement – A Comprehensive Survey




图像恢复与增强的扩散模型综述 论文链接&#xff1a;https://arxiv.org/abs/2308.09388 
项目地址&#xff1a;https://github.com/lixinustc/Awesome-diffusion-model-for-image-processing/ 
Abstract 
图像恢复(IR)一直是低水平视觉领域不可或缺的一项具有挑战性的任务&…...






编程日记
2023/8/27 1:57:18



















Springboot开发所遇问题(持续更新)




SpringBoot特征&#xff1a; 1. SpringBoot Starter&#xff1a;他将常用的依赖分组进行了整合&#xff0c;将其合并到一个依赖中&#xff0c;这样就可以一次性添加到项目的Maven或Gradle构建中。 2,使编码变得简单&#xff0c;SpringBoot采用 JavaConfig的方式对Spring进行配置…...






编程日记
2023/8/27 1:56:16



















智能电视与win10电脑后续无法实现DLNA屏幕共享




问题背景&#xff1a; 
我用的是TCL电视&#xff0c;但是并不是最新&#xff0c;打开的方式是U盘->电脑&#xff0c;各位看自己情况&#xff0c;很多问题都大概率是智能电视问题。 
情景假设&#xff1a; 假设你已经完成原先智能电视该有的步骤&#xff0c;通过DLNA&#xf…...






编程日记
2023/8/27 1:55:14



















如何可以管理监督员工工作微信？




自从微信管理系统研发上线之后&#xff0c;为了各企业带来了福音。 
很多用户企业都是这样评论微信管理系统的&#xff1a;员工的所有微信聊天记录后台都可以清楚明了的看到&#xff0c;聊天记录都是永久保存的&#xff0c;不担心员工在手机上把聊天记录删除&#xff0c;杜绝员…...






编程日记
2023/8/27 1:54:13



















【Django】如何转化已有的数据表到Django模型--20230823




初步生成model.py 
$ python manage.py inspectdb $ python manage.py inspectdb > models.py 
python manage.py inspectdb
# This is an auto-generated Django model module.
# Youll have to do the following manually to clean this up:
#   * Rearrange models order…...






编程日记
2023/8/27 1:53:11



















【C语言】喝汽水问题




大家好&#xff01;今天我们来学习C语言中的喝汽水问题&#xff01; 目录 
1. 题目内容&#xff1a; 
2. 思路分析 
2.1 方法一 
2.2 方法二 
2.3 方法三 
3. 代码实现 
3.1 方法一 
3.2 方法二 
3.3 方法三 1. 题目内容 
喝汽水&#xff0c;1瓶汽水1元&#xff0c;2个空瓶可以…...






编程日记
2023/8/27 1:52:10



















项目进度管理（4-2）关键链法和关键路径法的区别和联系




1 关键链法和关键路径法的主要区别 
1.1 关键链法和关键路径法的关注焦点不同 
关键路径法&#xff08;CPM&#xff09;&#xff1a;关注项目中最长的路径&#xff0c;也就是所需时间最长的路径&#xff0c;这被称为关键路径。关键路径决定了项目的最早完成时间。关键链法&…...






编程日记
2023/8/27 1:51:08



















基于Java+SpringBoot+Vue前后端分离医院后台管理系统设计和实现




博主介绍&#xff1a;✌全网粉丝30W,csdn特邀作者、博客专家、CSDN新星计划导师、Java领域优质创作者,博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ &#x1f345;文末获取源码联系&#x1f345; &#x1f447;&#x1f3fb; 精彩专…...






编程日记
2023/8/27 1:50:08



















二维数组传参




在C语言中&#xff0c;可以通过指针来传递二维数组。二维数组实际上是一个连续的内存块&#xff0c;可以使用指针来表示二维数组的行和列。以下是一个示例&#xff1a; 
#include <stdio.h>void myFunction(int arr[][3], int rows) {for (int i  0; i < rows; i) {fo…...






编程日记
2023/8/27 1:49:07



















AI 绘画Stable Diffusion 研究（十四）SD 图生图+剪映制作人物说话视频




大家好&#xff0c;我是风雨无阻。 前一篇&#xff0c;我们详细介绍了使用 SadTlaker制作数字人视频案例&#xff0c;感兴趣的朋友请前往查看:AI 绘画Stable Diffusion 研究&#xff08;十三&#xff09;SD数字人制作工具SadTlaker使用教程。 对于没有安装 SadTlaker 插件的朋友…...






编程日记
2023/8/27 1:48:05





















Python｜GIF 解析与构建（5）：手搓截屏和帧率控制




目录 Python&#xff5c;GIF 解析与构建&#xff08;5&#xff09;&#xff1a;手搓截屏和帧率控制 
一、引言 
二、技术实现&#xff1a;手搓截屏模块 
2.1 核心原理 
2.2 代码解析&#xff1a;ScreenshotData类 
2.2.1 截图函数&#xff1a;capture_screen 
三、技术实现&…...






编程新知
2025/11/14 3:06:30



















简易版抽奖活动的设计技术方案




1.前言 
本技术方案旨在设计一套完整且可靠的抽奖活动逻辑，确保抽奖活动能够公平、公正、公开地进行，同时满足高并发访问、数据安全存储与高效处理等需求，为用户提供流畅的抽奖体验，助力业务顺利开展。本方案将涵盖抽奖活动的整体架构设计、核心流程逻辑、关键功能实现以及…...






编程新知
2026/2/7 17:41:40



















python/java环境配置




环境变量放一起 python&#xff1a; 
1.首先下载Python 
Python下载地址&#xff1a;Download Python | Python.org 
downloads ---windows -- 64 2.安装Python  
下面两个&#xff0c;然后自定义&#xff0c;全选 可以把前4个选上  3.环境配置 
1&#xff09;搜高级系统设置 2…...






编程新知
2026/2/9 15:41:39



















java 实现excel文件转pdf | 无水印 | 无限制




文章目录 目录 
文章目录 
前言 
1.项目远程仓库配置 
2.pom文件引入相关依赖 
3.代码破解  
二、Excel转PDF 
1.代码实现 
2.Aspose.License.xml 授权文件 
总结 前言 java处理excel转pdf一直没找到什么好用的免费jar包工具，自己手写的难度，恐怕高级程序员花费一年的事件，也…...






编程新知
2025/11/5 4:10:42



















DBAPI如何优雅的获取单条数据




API如何优雅的获取单条数据 
案例一 
对于查询类API&#xff0c;查询的是单条数据&#xff0c;比如根据主键ID查询用户信息&#xff0c;sql如下&#xff1a; 
select id, name, age from user where id  #{id}API默认返回的数据格式是多条的&#xff0c;如下&#xff1a; 
{&qu…...






编程新知
2026/2/2 22:06:13



















【C++从零实现Json-Rpc框架】第六弹 —— 服务端模块划分




一、项目背景回顾 前五弹完成了Json-Rpc协议解析、请求处理、客户端调用等基础模块搭建。  本弹重点聚焦于服务端的模块划分与架构设计&#xff0c;提升代码结构的可维护性与扩展性。  二、服务端模块设计目标 高内聚低耦合&#xff1a;各模块职责清晰&#xff0c;便于独立开发…...






编程新知
2025/10/13 4:15:41



















OPenCV CUDA模块图像处理-----对图像执行 均值漂移滤波（Mean Shift Filtering）函数meanShiftFiltering()




操作系统&#xff1a;ubuntu22.04 OpenCV版本&#xff1a;OpenCV4.9 IDE:Visual Studio Code 编程语言&#xff1a;C11 
算法描述 
在 GPU 上对图像执行 均值漂移滤波&#xff08;Mean Shift Filtering&#xff09;&#xff0c;用于图像分割或平滑处理。 
该函数将输入图像中的…...






编程新知
2026/1/20 12:53:30



















rnn判断string中第一次出现a的下标




# coding:utf8
import torch
import torch.nn as nn
import numpy as np
import random
import json"""
基于pytorch的网络编写
实现一个RNN网络完成多分类任务
判断字符 a 第一次出现在字符串中的位置
"""class TorchModel(nn.Module):def __in…...






编程新知
2025/9/24 16:25:00



















Hive 存储格式深度解析：从 TextFile 到 ORC，如何选对数据存储方案？




在大数据处理领域&#xff0c;Hive 作为 Hadoop 生态中重要的数据仓库工具&#xff0c;其存储格式的选择直接影响数据存储成本、查询效率和计算资源消耗。面对 TextFile、SequenceFile、Parquet、RCFile、ORC 等多种存储格式&#xff0c;很多开发者常常陷入选择困境。本文将从底…...






编程新知
2025/12/6 10:54:35



















C语言中提供的第三方库之哈希表实现




一. 简介 
前面一篇文章简单学习了C语言中第三方库&#xff08;uthash库&#xff09;提供对哈希表的操作&#xff0c;文章如下&#xff1a; 
C语言中提供的第三方库uthash常用接口-CSDN博客 
本文简单学习一下第三方库 uthash库对哈希表的操作。 二. uthash库哈希表操作示例 
u…...






编程新知
2025/11/9 14:40:17