kafka 基础

举报
kaliarch 发表于 2023/12/10 13:42:13 2023/12/10
【摘要】 概述Kafta基于命令、参数和标志的结构构建。Kafka始终在一个集群上进行交互,这样就不需要在每个命令中传递哪个集群的信息,这与大多数Kafka命令行工具不同。要查看所有可用的命令,请运行:$ kafta用法:kafta [command]可用命令:broker     broker管理cluster    集群管理completion 输出shell补全代码config     修改配置...

概述

Kafta基于命令、参数和标志的结构构建。Kafka始终在一个集群上进行交互,这样就不需要在每个命令中传递哪个集群的信息,这与大多数Kafka命令行工具不同。
要查看所有可用的命令,请运行:

$ kafta
用法:
kafta [command]

可用命令:
broker     broker管理
cluster    集群管理
completion 输出shell补全代码
config     修改配置文件
console    控制台管理
consumer   消费者组管理
help       获取任何命令的帮助
schema     模式注册表管理
topic      主题管理
version    打印Kafta版本

标志:
--context string       要使用的kafkaconfig上下文的名称
-d,--debug                调试模式
-h,--help                 kafta的帮助信息
--kafkaconfig string  kafkaconfig文件的路径

使用“kafta [command] --help”获取有关命令的更多信息。

要查看与同一命令相关的所有选项,请运行:

$ kafta topic
主题管理

用法:
kafta topic [command]

可用命令:
create     创建主题
delete     删除主题
describe   描述主题
list         列出主题

简单命令

Kafta与其他命令行工具非常相似,它的设计初衷是避免思考“这个命令的语法是什么”。一个很好的例子是创建一个主题。非常简单,只需运行以下命令:

$ kafta topic create my-topic --rf 3 --partitions 10
主题已创建

就是这样!您的主题已创建。默认情况下,分区和副本因子有默认值,这就是为什么可以不指定RF或分区来使用它。该主题将使用RF=3和分区=10进行创建。例如:

$ kafta topic create my-topic
主题已创建

安装

使用go get安装最新版本。该命令将安装Kafta可执行文件以及库和其依赖项:
go < 1.18:go get -u github.com/electric-saw/kafta
go >= 1.18:go install github.com/electric-saw/kafta/cmd/kafta@latest
如果您愿意,也可以直接下载二进制文件并在您的计算机上运行,无论何时何地。

上下文和配置

Kafta将在~/.kafta/config中创建一个配置文件。该YAML文件用于支持Kafka多集群,并避免每次都传递所有地址。
Kafta中的每个集群称为上下文,Kafta的目标是成为一个不仅仅是简单的Kafka管理工具,还能管理模式注册表、连接和Kafka环境的其他部分,我们将这个组称为上下文。
要设置一个新的上下文以下是链接内容的翻译:

Kafta是一个现代化的非JVM命令行工具,用于管理Kafka集群。

经过几个晚上、周末和深夜的努力,今天我们发布了Kafta的第一个稳定版本。这个项目是我和@snakeice一起创建的。我们花了几天时间使用Apache Kafka自带的原生命令,但感到非常沮丧。

Kafta是由开发人员为开发人员创建的。我们深知使用Apache Kafka提供的bash命令来维护Kafka集群的困难和痛苦。为了简化使用Kafka,我们开始着手开发Kafta。Kafta是一个使用Go语言开发的项目,安装、配置和使用都非常简单。

概述

Kafta的命令、参数和标志构成了其结构。Kafta始终在一个集群上进行操作,这样就无需在每个命令中指定集群,与其他大多数Kafka命令行工具不同。

要查看所有可用的命令,请运行以下命令:

$ kafta
用法:
kafta [command]

可用命令:
broker:管理broker
cluster:管理集群
completion:输出shell补全代码
config:修改配置文件
console:管理控制台
consumer:管理消费者组
help:获取任意命令的帮助
schema:管理Schema Registry
topic:管理主题
version:打印Kafta的版本

标志:
--context string:要使用的kafkaconfig上下文的名称
-d,--debug:调试模式
-h,--help:kafta的帮助信息
--kafkaconfig string:kafkaconfig文件的路径

要查看与特定命令相关的所有选项,请运行以下命令:

$ kafta topic
主题管理

用法:
kafta topic [command]

可用命令:
create:创建主题
delete:删除主题
describe:描述主题
list:列出主题

简单命令

Kafta与其他命令行工具非常相似,它的设计目标是避免思考“这个命令的语法是什么”。例如,创建一个主题非常简单,只需运行以下命令:

$ kafta topic create my-topic --rf 3 --partitions 10
主题已创建

就是这样!您的主题已创建。如果不指定RF或分区,将使用默认值创建主题。默认情况下,主题将以RF=3和分区=10的配置创建。例如:

$ kafta topic create my-topic
主题已创建

安装

使用go get命令安装最新版本。该命令将安装Kafta可执行文件以及其库和依赖项:

go < 1.18:go get -u github.com/electric-saw/kafta
go >= 1.18:go install github.com/electric-saw/kafta/cmd/kafta@latest

如果您愿意,也可以直接下载二进制文件,并在任何地方的计算机上运行。

上下文和配置

Kafta将在~/.kafta/config目录下创建一个配置文件。该配置文件使用YAML格式,

$ kafta config set-context production
Bootstrap servers: b-1.mydomain:9092,b-2.mydomain:9092,b-3.mydomain:9092
Schema registry: https://schema-registry.com
Use SASL: y
SASL Algorithm: sha512
User: myuser
✔ Password: ******

要列出上下文,请运行:这部分是Kafta的微分。它是为具有许多集群的环境而设计的,从一个集群轻松移动到另一个集群非常重要。

【版权声明】本文为华为云社区用户原创内容,未经允许不得转载,如需转载请自行联系原作者进行授权。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。