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。