Apache Kafka
在树中右键 ▸ 添加 ▸ Kafka 请求。
| 字段 | 作用 |
|---|---|
| URL | 以逗号分隔的消息代理列表：hote1:9092,hote2:9092 —— 整个字符串会先由 Handlebars 解析，然后才被切分 |
| 客户端标识 | 向消息代理声明的 clientId |
| 主题 | 主题，所有模式下都需要 |
| 模式 | produce、consume 或 browse |
| 字段 | 取值 |
|---|---|
| SASL 机制 | none、plain、scram-sha-256、scram-sha-512 |
| SASL 用户名 / SASL 密码 | 密码接受密钥类型的值 |
| TLS | 可独立启用 —— 启用 TLS 但不使用 SASL 的消息代理配合 none 机制即可工作 |
produce 模式
Section titled “produce 模式”键、值、记录头，以及可选的分区。未显式指定分区时，将使用客户端库的默认分区器。 响应会返回所写入记录的元数据：主题、分区、偏移量。
consume 模式
Section titled “consume 模式”| 字段 | 作用 |
|---|---|
| 组 | 消费者的 groupId |
| 起始偏移量 | earliest、latest 或 specific |
| 指定偏移量 | 一个字符串 —— Kafka 的偏移量是 64 位整数 |
| 分区 | 一个客户端侧过滤器：分区分配仍由消费者组负责 |
browse 模式
Section titled “browse 模式”在不使用消费者组的情况下检视一个分区：Restorm 从中取出数量有限的消息，然后断开连接。 该模式下必须指定分区。
想看看某个主题里有什么内容、又不想创建消费者组或移动偏移量时，这就是合适的工具。
- Kafka 生产 —— 单次动作，返回记录的元数据；
- Kafka 消费 —— 通过消费者组订阅，并为每条消息发出一个事件；
- Kafka 关闭连接 —— 停止消费。
参见连接与流。
五个目标：JavaScript（kafkajs，覆盖生产和消费）和 kcat
（生产、消费、无消费者组检视）。