8

kcctl:Apache Kafka Connect的命令行客户端CLI

 1 year ago
source link: https://www.jdon.com/67651.html
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
neoserver,ios ssh client

kcctl:Apache Kafka Connect的命令行客户端CLI

Kafka Connect 的现代且直观的命令行客户端。

该项目是Kafka Connect的命令行客户端。依靠kubectl的习惯用法和语义,它允许您注册和检查连接器、删除它们、重新启动它们等。

这说明Java也是构建敏捷CLI应用程序的好选择,即时启动GraalVM原生二进制文件,如同在linux的shell中启动任何命令一样,没有任何明显延迟。

例如kcctl通过REST检索kafka连接器名称时,几乎毫无延迟。

显示帮助以了解如何使用kcctl:

kcctl help
使用方法:kcctl [-hV] [COMMAND]
A command-line interface for Kafka Connect
  -h, --help      显示帮助信息并退出。
  -V, --version   打印版本信息并退出。
命令:
  info      显示 Kafka Connect 集群的信息
  config    设置或检索此客户端的配置
  get      显示连接器插件、连接器偏移量等信息
 ;      创建的连接器和记录器的信息
  describe  显示指定资源的详细信息
  apply    应用给定的文件或 stdin 内容进行注册或
 ;更新连接器
        patch     修改某些连接器或日志记录器的配置
  restart   重启某些连接器或任务
  pause     暂停连接器
 ;resume    恢复连接器
  stop    停止(但不删除)连接器
  delete    删除连接器
  help    显示指定命令的帮助信息。
注意项

在开始使用kcctl之前,您需要创建一个配置上下文。配置上下文是一组配置参数,按名称分组,描述一个特定的 Kafka Connect 环境。所有后续命令将使用当前活动上下文执行。

要创建名为 的配置上下文local,并将 Kafka Connect 集群 URL 设置为 http://localhost:8083,请发出以下命令

kcctl config set-context local --cluster http://localhost:8083

 请注意,某些命令需要额外的参数,例如bootstrap-servers和 offset-topic。

键入kcctl info以显示有关 Kafka Connect 集群的一些信息。该命令将使用当前活动的上下文(local在本例中)来解析集群 URL。


About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK