首页 > 其他分享 >Kafka 主题 CLI 教程

Kafka 主题 CLI 教程

时间:2024-06-09 19:44:58浏览次数:28  
标签:教程 CLI -- topics Kafka topic kafka localhost

Kafka Topics CLI,即kafka-topics用于创建、删除、描述或更改 Kafka 中的主题。请确保您已预先启动 Kafka 

如何创建 Kafka 主题?

要创建 Kafka 主题,我们需要提供必需的参数:

  • 如果是 Kafka v2.2+,请使用 Kafka 主机名和端口,例如,localhost:9092

  • 如果是旧版本的 Kafka,请使用 Zookeeper URL 和端口,例如localhost:2181

  • 提供必需参数:主题名称、分区数和复制因子。

  • 使用kafka-topics.sh带有--create选项的CLI

重要建议:如果你使用 Kafka v2.2+

如果您拥有最新版本的 Kafka,我们强烈建议您使用带有该--bootstrap-server选项的命令,因为 Zookeeper 选项现已弃用并作为 Kafka v3 的一部分被删除。

   

例子

first_topic当我的 Kafka 代理运行时,创建具有 3 个分区和 1 个复制因子的 Kafka 主题localhost:9092

Kafka v2.2+

kafka-topics.sh --bootstrap-server localhost:9092 --topic first_topic --create --partitions 3 --replication-factor 1

Kafka v2.1 或更低版本:

kafka-topics.sh --zookeeper localhost:2181 --topic first_topic --create --partitions 3 --replication-factor 1

命令输出

WARNING: Due to limitations in metric names, topics with a period ('.') or underscore ('_') could collide. To avoid issues it is best to use either, but not both.
Created topic first_topic.

陷阱

以下是该命令的常见错误和注意事项kafka-topics.sh --create

  • 您不能指定大于您拥有的代理数量的复制因子

  • 你可以指定任意数量的分区,在开发中,3 是一个不错的选择

  • 如果运行命令后看到文档,则表示你的命令是错误的。向上滚动可查看有关错误消息的详细信息

  • 分区和复制因子没有默认值,您必须明确指定

  • 主题名称只能包含 ASCII 字母数字、“.”、“_”和“-”

您可以设置的额外重要选项(高级)

--config

例如,您可以设置主题级别的配置--config max.message.bytes=64000

--disable-rack-aware

禁用机架感知副本分配(不推荐,仅当您知道自己在做什么时才设置)

如何列出 Kafka 主题?

要列出 Kafka 主题,我们需要提供必需的参数:

  • 如果是 Kafka v2.2+,请使用 Kafka 主机名和端口,例如,localhost:9092

  • 如果是旧版本的 Kafka,请使用 Zookeeper URL 和端口,例如localhost:2181

  • 使用kafka-topics.sh带有--list选项的CLI

例子

当我的 Kafka 代理运行时列出主题localhost:9092

Kafka v2.2+

kafka-topics.sh --bootstrap-server localhost:9092 --list

。。。。。。

标签:教程,CLI,--,topics,Kafka,topic,kafka,localhost
From: https://www.cnblogs.com/wonchaofan/p/18239914

相关文章

  • 02-软件教程资料
    目录页1.设计教程1.1.图形处理1.2.影视动画1.设计教程1.1.图形处理图形处理Photoshop(图片照片处理)PS基础实操课程Illustrator(矢量图形处理)1.2.影视动画影视动画Premiere(视频编辑)AfterEffects(图形视频处理)Cin......
  • MATLAB CLI 使用
    启动MATLABCli(需要已安装MATLAB):matlab-nodesktop-nosplash#无桌面环境,无启动动画基本操作赋值操作:a=5;%将5赋值给变量a显示变量:disp(a);%显示变量a的值矩阵与向量创建向量:v=[1,2,3,4];%行向量v=[1;2;3;4];%列向量创建......
  • 仿东郊到家《十大教程》公众号+小程序+APP 往约到家 上门预约服务 全开源 运营版 预约
    修复技师定位问题1、数据概况(新增业务城市用户投票功能,更加直观的查看业务城市的关注度、人气和影响力,促进业务开展)2、数据概况(增加可视化数据大盘,代理商端可查看自己下面的技师服务时长、在线时长、业绩、积分、加钟率、退单率、退单数量、总订单量等数据,更加直观的查看......
  • RocketMQ教程(三):RocketMQ的核心组件
    四个核心组件RocketMQ的架构采用了典型的分布式系统设计理念,以确保高性能、高可用和可扩展性。RocketMQ主要由四个核心组件构成:NameServer、Broker、Producer和Consumer。下面是对这些组件以及它们在RocketMQ中的角色和功能的概述:1.NameServer角色和功能:NameServer......
  • kali2022安装教程(附安装包)
    第一步:下载镜像文件百度网盘下载[链接:https://pan.baidu.com/s/1efRQGFTbq6Kgw9axLOmWzg?pwd=emxf()第二步:打开Vmware创建新的虚拟机,选择高级,然后下一步直接默认下一步选择稍后安装然后下一步kali属于Debian系统所以这里直接选择Debian664位进行命名和选择安装位置......
  • Ventoy使用教程
    Ventoy是一款开源的USB启动盘制作工具,它允许用户将多种类型的操作系统镜像文件(如ISO、WIM、IMG等)直接拷贝到U盘,而无需反复格式化U盘。本教程将详细介绍Ventoy的使用步骤,帮助用户轻松制作USB启动盘。一、准备工作下载Ventoy:访问Ventoy官网(https://www.ventoy.net/cn/index.ht......
  • 《手把手教你》系列练习篇之15-python+ selenium自动化测试 -番外篇 - 最后一波啊!!!(详细
    1.简介 本来上一篇就是练习篇的最后一篇文章了,但是有的小伙伴私下反映说是做了那么多练习,没有一个比较综合的demo练练手。因此宏哥在这里又补存了一些常见的知识点进行练习,在文章最后也通过实例给小伙伴们或者童鞋们进行了一个登录模块的自动化测试的实例,其他的你可以照......
  • 《手把手教你》系列练习篇之14-python+ selenium自动化测试 -压台篇(详细教程)
    1.简介 本文是练习篇的最后一篇文章,虽然练习篇的文章到此就要和大家说拜拜了,但是我们的学习之路才刚刚开始。不要停下你的脚步,大步朝前走吧!比你优秀的人还在走着,我们有什么理由停下自己的脚步了,生命不止,学习亦是如此。好了,宏哥的毒鸡汤好喝吧,喝够了就开始学习吧。......
  • upload-labs第五关教程
    upload-labs第五关教程一、源代码分析代码审计.user.ini介绍二、绕过分析1)点空格点绕过上传一个eval.php文件使用burpsuite进行抓包修改放包进行中国蚁剑连接2).user.ini绕过编写一个.user.ini文件修改配置文件php.ini将.user.ini保存在www文件夹下。再上传eval.png使......
  • 2024 IDEA最新永久使用码教程(2099版)
    本篇文章我就来分享一下2024年当前最新版IntelliJIDEA最新注册码,教程如下,可免费永久,亲测有效,适合Windows和Mac。本教程适用于JB全系列产品,包括Pycharm、IDEA、WebStorm、Phpstorm、Datagrip、RubyMine、CLion、AppCode等。(希望大家且用且珍惜)9H1390TRAK-eyJsaWNlbnN......