kafka 基础
概述
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的微分。它是为具有许多集群的环境而设计的,从一个集群轻松移动到另一个集群非常重要。
- 点赞
- 收藏
- 关注作者
评论(0)