首页 > 其他分享 >Kafka命令

Kafka命令

时间:2023-08-26 20:32:06浏览次数:29  
标签:bin -- kafka topic 命令 sh Kafka localhost

以下是一些常用的Kafka命令及其用途:

  1. 启动Kafka服务:
bin/kafka-server-start.sh config/server.properties
  1. 创建一个主题(topic):
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic myTopic
  1. 列出所有主题:
bin/kafka-topics.sh --list --zookeeper localhost:2181
  1. 查看特定主题的详细信息:
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic myTopic
  1. 发送消息到指定主题:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic myTopic
  1. 从指定主题消费消息:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic myTopic --from-beginning
  1. 查看消费者组的偏移量:
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group myGroup --describe
  1. 在消费者组中重置偏移量:
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group myGroup --reset-offsets --to-earliest --execute --topic myTopic

这只是一些基本的Kafka命令示例,Kafka还有许多其他功能和命令可以根据需要使用。你可以参考Kafka官方文档来了解更多详细信息和更高级的用法。

标签:bin,--,kafka,topic,命令,sh,Kafka,localhost
From: https://blog.51cto.com/u_16161880/7246074

相关文章

  • 遇到的Docker常用命令
    遇到的Docker常用命令一、安装Docker1)Docker要求CentOS系统的内核版本高于3.10,首先查看系统内核版本是否满足uname-r2)使用root权限登录系统,确保yum包更新到最新sudoyumupdate-y3)假如安装过旧版本,先卸载旧版本sudoyumremovedockerdocker-commondocker-sel......
  • Linux磁盘划分,命令汇总
    当有一块新的硬盘添加至Linux后需要在Linux下进行一定的操作后才能正常使用,其大概流程为:先对磁盘进行分区(或者不进行),再将分区设置为物理卷,将设置好的物理卷添加到现有某一卷组下或创建一个新卷组,再将卷组内的多余空间分配至原有的逻辑卷内或者建立新的逻辑卷如果是分配到新的逻......
  • 怎么使用Kafka?收藏这篇短文就可以了
    〇、前言便于大家对本章内容的理解,我重新整理了一下Kafka中的部分重要概念,以表格的方式呈现出来,请见下表所示:名词解释Broker节点一个Kafka节点就是一个Broker,一个和多个Broker可以组成一个Kafka集群Topic主题Kafka根据topic对消息进行归类,发布到kafka集群的每套......
  • 设计模式-命令模式
    命令模式模式定义命令模式是一种行为定义模式,可以将请求转换成一个与请求相关的,包含该请求所有信息的独立对象,并且能够根据不同请求将方法参数化,延迟请求执行或者将其放入到队列中且能实现撤销等操作模式动机敏捷开发的原则要求,不要在代码上添加基于猜测的,实际上不需要的功......
  • 【面试宝典】Git 版本控制常用命令
    一.Git概述Git是目前世界上最先进的分布式版本控制工具,主要用于管理开发过程中的源代码文件(Java类、xml文件、html页面等),包括:代码回溯:Git在管理文件过程中会记录日志,方便回退到历史版本版本切换:Git存在分支的概念,一个项目可以有多个分支(版本),可以任意切换多人协作:Git支......
  • Linux命令
     文章目录1.用户管理2.磁盘管理3.文件管理4.进程管理a.查看进程b.服务管理c.后台运行(守护进程)d.启动项5.软件管理a.rpm包之手动安装b.rpm包之yum安装c.源代码安装d.二进制安装6.防火墙a.netflter/iptables功能b.iptables:“五表五链”c.fi......
  • Allure常用命令
    命令格式:allure [option]  [command]  [commandoptions]allure--help帮助allure--version查看版本信息allureserve 生成在线版本的测试alluregenerate<allure-result中间文件> -o  输出目录(默认路径:allure-report)引入依赖<?xmlversion="1.0"e......
  • shell命令概述 Shell作用:命令解释器 介于操作系统内核与用户之间,负责解释命令行 获得
    shell命令概述Shell作用:命令解释器介于操作系统内核与用户之间,负责解释命令行获得命令帮助内部命令help命令的“--help”选项使用man命令阅读手册页命令行编辑的几个辅助操作Tab键:自动补齐反斜杠“\”:强制换行快捷键Ctrl+U:清空至行首快捷键Ctrl+K:清空至行尾快捷键Ctr......
  • shell命令概述 Shell作用:命令解释器 介于操作系统内核与用户之间,负责解释命令行 获得
    shell命令概述Shell作用:命令解释器介于操作系统内核与用户之间,负责解释命令行获得命令帮助内部命令help命令的“--help”选项使用man命令阅读手册页命令行编辑的几个辅助操作Tab键:自动补齐反斜杠“\”:强制换行快捷键Ctrl+U:清空至行首快捷键Ctrl+K:清空至行尾快捷键Ctr......
  • git_使用git worktree命令使不同分支的代码文件可以同步运行
    情景再现:我本地代码正在开发后台系统的过程中,前台开发的同事时不时地会来找我要IP地址,使用正在开发的后台管理系统来进行一些数据的增删改查.这个时候直接提供正在开发的版本的开发服务器地址是不行的,因为随着代码的编写时不时的报个bug是家常便饭,对于使用者来说非常......