Kafka Connect 的现代且直观的命令行客户端。
该项目是Kafka Connect的命令行客户端。依靠kubectl的习惯用法和语义,它允许您注册和检查连接器、删除它们、重新启动它们等。
这说明Java也是构建敏捷CLI应用程序的好选择,即时启动GraalVM原生二进制文件,如同在linux的shell中启动任何命令一样,没有任何明显延迟。
例如kcctl通过REST检索kafka连接器名称时,几乎毫无延迟。
显示帮助以了解如何使用kcctl:
kcctl 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。