跳转到正文

每天都用 TablePro?购买许可证即可使用付费功能,并支持下个版本的开发。 购买许可证购买许可证,支持 TablePro

适用于 Mac 的 Apache Kafka 客户端

用 KafkaQL 从所选起点读取主题,查看每个消费者组的延迟,并生成测试消息。主题是日志,所以网格仅读取消息,从不编辑。

适用于 Mac首次选择 Apache Kafka 时下载驱动

针对 orders 主题的 KafkaQL CONSUME 语句,消息按分区、偏移量、键和时间戳列出。

概览

查询语言
KafkaQL
驱动
首次使用时下载
连接方式
主机和端口, SSH 隧道, SSL/TLS
默认端口
9092
最低版本
0.11,文档所述
iPhone 和 iPad
无法打开

连接

输入一个代理的主机和端口,从它发现集群其余部分。Additional Bootstrap Servers 列出首个代理无响应时尝试的代理。一个连接对应一个集群,无 Database 字段,侧栏直接显示主题。

Security Protocol 可选 PLAINTEXT、SSL、SASL_PLAINTEXT、SASL_SSL,SASL Mechanism 可选 PLAIN、SCRAM-SHA-256、SCRAM-SHA-512。PLAIN 适合 Confluent Cloud,SCRAM 适合 Amazon MSK 和自托管代理。SSL 或 SASL_SSL 未选择 SSL 模式时验证证书链和主机名。私有 CA 填入 CA Certificate,客户端证书和密钥提供双向 TLS。

通过 SSH 隧道时连接停留在引导代理,仅读取该代理领导的分区。Import from URL… 接受 kafka:// URL,macOS 不将其作为链接打开。

读取、检查和生成

打开主题显示最近消息,最新在最后,含分区、偏移量、时间戳、键、值、头和大小。不同分区的消息按时间戳交错以方便阅读;真正标识消息的是分区和偏移量。非 UTF-8 的键或值显示为十六进制,tombstone 与空消息保持区别。

KafkaQL 用起始位置替代排序和筛选:CONSUME "orders" FROM NEWEST、FROM OLDEST、FROM OFFSET,或带 ISO 8601 时间戳的 FROM TIME,可限定部分分区。SHOW TOPICS、SHOW BROKERS、SHOW GROUPS、SHOW CLUSTER、DESCRIBE TOPIC 查看集群其他信息。

DESCRIBE GROUP 是延迟报告,逐分区显示已提交偏移、末端偏移和差值。组从未提交过的分区显示无延迟,而不是从零计算。代理不可达时 SHOW GROUPS 标注列表已截断。

PRODUCE INTO 写入消息,可选键、头和分区。有键但未指定分区的消息落在 Kafka 自身生产者会选择的位置。读取时自动解压 gzip、snappy、lz4、zstd 批次,无需选择设置。

Kafka 无更新、逐消息删除或服务器端排序,因此无法编辑单元格、删除行或按列排序,相应控件显示禁用。每页从上页停止处继续,因此持续写入的主题也不重复或跳过消息。

主题

从侧栏或 DROP TOPIC 删除主题是唯一破坏性操作。集群随后移除日志,主题可能暂留列表。不提供 Truncate:Kafka 按保留策略或各分区偏移移除记录,两者均不清空主题。

移动数据

不提供导入;用 PRODUCE INTO 向主题写消息。将查询读取的消息导出为 CSV、JSON 或 XLSX。

iPhone 和 iPad

iPhone 和 iPad 应用没有 Apache Kafka 驱动。从 Mac 同步的 Apache Kafka 连接会显示在列表中,但无法打开。

限制

  • 不读取 Schema Registry,因此 Avro 和 Protobuf 值显示为原始字节。
  • 不支持创建主题、编辑主题配置或重置消费者组偏移量。
  • 消息数量为近似值。

关于 Apache Kafka 的问题

为什么主题能加载但消息超时?

集群公布了此 Mac 无法访问的地址,如容器主机名或私有 IP。请修正 advertised.listeners,或设置 Broker Addresses 仅用引导地址。

支持 Amazon MSK IAM 登录吗?

不支持。提供的 SASL 机制为 PLAIN、SCRAM-SHA-256、SCRAM-SHA-512,请在 MSK 集群创建 SCRAM 用户,以 SASL_SSL 连接。

获取 TablePro

Mac 应用可免费下载和使用。Starter 或 Team 方案添加可选功能。
下载 Mac 版

需要 macOS 13 Ventura 或更新版本