插件
kafka
kafka 分布式流处理平台
上传者：chariot
版本：4.0.0
kafka
概述
帮助
具体内容
下载
chariot plugin download chariot/kafka:4.0.0
描述
kafka 分布式流处理平台
触发器
- 消费者接受信息
动作
- kafka 主题
- 查看配置
- 生产者发送信息
- 简单快速地发送一条消息
kafka
关于
kafka 分布式流处理平台动作
获取已有主题
kafka 主题.
输入
| Name | Type | Default | Required | Description | Enum |
|---|---|---|---|---|---|
| bootstrap_servers | []string | ["172.36.0.1:9092"] | False | 服务器列表 | None |
输出
| Name | Type | Required | Description |
|---|---|---|---|
| topic_list | []string | True | 主题列表 |
查看配置信息
查看配置.
输入
| Name | Type | Default | Required | Description | Enum |
|---|---|---|---|---|---|
| bootstrap_servers | []string | None | False | 服务器列表，例如 ["127.0.0.1:9092","127.0.0.2:9092"] | None |
输出
| Name | Type | Required | Description |
|---|---|---|---|
| info | object | True | 配置信息 |
发送信息
生产者发送信息.
输入
| Name | Type | Default | Required | Description | Enum |
|---|---|---|---|---|---|
| topic | string | None | True | 主题 | None |
| bootstrap_servers | []string | ["172.36.0.1:9092"] | True | 服务器列表，例如 ["127.0.0.1:9092","127.0.0.2:9092"] | None |
| msg | []msg_type | None | True | 发送消息，例如 [{"key":"k1","value":"never gonna let u down"},{"key":"k1","value":"never gonna give u up"}] | None |
输出
| Name | Type | Required | Description |
|---|---|---|---|
| log | string | True | 消息是否发送成功 |
简单快速地发送一条消息
简单快速地发送一条消息.
输入
| Name | Type | Default | Required | Description | Enum |
|---|---|---|---|---|---|
| bootstrap_servers | []string | ["172.36.0.1:9092"] | True | 服务器列表，例如 ["127.0.0.1:9092","127.0.0.2:9092"] | None |
| topic | string | None | True | 主题 | None |
| msg | string | Hello | True | None | None |
输出
| Name | Type | Required | Description |
|---|---|---|---|
| log | string | True | 消息是否发送成功 |
触发器
接受信息
消费者接受信息.
输入
| Name | Type | Default | Required | Description | Enum |
|---|---|---|---|---|---|
| topic | string | None | True | 主题 | None |
| bootstrap_servers | []string | ["172.36.0.1:9092"] | False | 服务器列表，例如 ["127.0.0.1:9092","127.0.0.2:9092"] | None |
输出
| Name | Type | Required | Description |
|---|---|---|---|
| jsonmsg | object | None | |
| key | string | 键 | |
| value | string | 值 |
连接
该插件不包含任何连接。
故障排除
该插件不包含任何故障排除信息。
版本
- 4.0.0 -
- 3.0.0 -
- 2.0.0 -
- 1.0.0 -
- 0.1.9 -
- 0.1.8 -
- 0.1.7 -
- 0.1.5 -
- 0.1.4 -
- 0.1.2 -
索引
该插件不包含任何索引。
plugin_spec_version: v2
name: kafka
title: Kafka
description: kafka 分布式流处理平台
version: 4.0.0
sdk: 1.3.2
vendor: chariot
tags:
- kafka
types:
msg_type:
key:
title:
en: Key
zh-CN: 键
type: string
required: true
value:
title:
en: Value
zh-CN: 值
type: string
required: true
triggers:
receiver_msg:
title: 接受信息
description: 消费者接受信息
input:
topic:
title:
en: Topic
zh-CN: 主题
type: string
description:
en: The theme
zh-CN: 主题
required: true
bootstrap_servers:
title:
en: Bootstrap_servers
zh-CN: 服务器列表
type: "[]string"
description:
en: Server list, e.g ["127.0.0.1:9092","127.0.0.2:9092"]
zh-CN: 服务器列表，例如 ["127.0.0.1:9092","127.0.0.2:9092"]
required: false
default:
- 172.36.0.1:9092
output:
jsonmsg:
title:
en: Json Messages
zh-CN: Json 格式的消息
type: object
key:
title:
en: Key
zh-CN: 键
type: string
description:
en: key
zh-CN: 键
value:
title:
en: Value
zh-CN: 值
type: string
description:
en: value
zh-CN: 值
indicator_receivers:
rece_msg_indicator:
title:
en: Rece_msg
zh-CN: 接受信息
description:
en: Consumer acceptance of information
zh-CN: 消费者接受信息
input:
topic:
title:
en: Topic
zh-CN: 主题
type: string
description:
en: The theme
zh-CN: 主题
required: true
bootstrap_servers:
title:
en: Bootstrap_servers
zh-CN: 服务器列表
type: "[]string"
description:
en: Server list, e.g ["127.0.0.1:9092","127.0.0.2:9092"]
zh-CN: 服务器列表，例如 ["127.0.0.1:9092","127.0.0.2:9092"]
required: false
default:
- 172.36.0.1:9092
alarm_receivers:
rece_msg:
title:
en: Rece_msg
zh-CN: 接受信息
description:
en: Consumer acceptance of information
zh-CN: 消费者接受信息
input:
topic:
title:
en: Topic
zh-CN: 主题
type: string
description:
en: The theme
zh-CN: 主题
required: true
bootstrap_servers:
title:
en: Bootstrap_servers
zh-CN: 服务器列表
type: "[]string"
description:
en: Server list, e.g ["127.0.0.1:9092","127.0.0.2:9092"]
zh-CN: 服务器列表，例如 ["127.0.0.1:9092","127.0.0.2:9092"]
required: false
default:
- 172.36.0.1:9092
encoding:
title:
en: Message Encoding
zh-CN: 消息编码
type: string
default: utf-8
enum:
- utf-8
- gbk
- ascii
focus:
title:
en: Focus Decode
zh-CN: 强制解码
type: boolean
default: true
actions:
topics:
title: 获取已有主题
description: kafka 主题
input:
bootstrap_servers:
title:
en: Bootstrap_servers
zh-CN: 服务器列表
type: "[]string"
description:
en: Server list
zh-CN: 服务器列表
required: false
default:
- 172.36.0.1:9092
output:
topic_list:
title:
en: Topic_list
zh-CN: 主题列表
type: "[]string"
description:
en: List of topics
zh-CN: 主题列表
required: true
config_info:
title: 查看配置信息
description: 查看配置
input:
bootstrap_servers:
title:
en: Bootstrap_servers
zh-CN: 服务器列表
type: "[]string"
description:
en: Server list, e.g ["127.0.0.1:9092","127.0.0.2:9092"]
zh-CN: 服务器列表，例如 ["127.0.0.1:9092","127.0.0.2:9092"]
required: false
output:
info:
title:
en: Info
zh-CN: 信息
type: object
description:
en: Configuration information
zh-CN: 配置信息
required: true
send_msg:
title: 发送信息
description: 生产者发送信息
input:
topic:
title:
en: Topic
zh-CN: 主题
type: string
description:
en: The theme
zh-CN: 主题
required: true
bootstrap_servers:
title:
en: Bootstrap_servers
zh-CN: 服务器列表
type: "[]string"
description:
en: Server list, e.g ["127.0.0.1:9092","127.0.0.2:9092"]
zh-CN: 服务器列表，例如 ["127.0.0.1:9092","127.0.0.2:9092"]
required: true
default:
- 172.36.0.1:9092
msg:
title:
en: Msg
zh-CN: 消息
type: "[]msg_type"
description:
en: Send a message, e.g [{"key":"k1","value":"hello there"},{"key":"k1","value":"never gonna give u up"}]
zh-CN: 发送消息，例如 [{"key":"k1","value":"never gonna let u down"},{"key":"k1","value":"never gonna give u up"}]
required: true
output:
log:
title:
en: Log
zh-CN: 日志
type: string
description:
en: Whether the message was sent successfully
zh-CN: 消息是否发送成功
required: true
easy_send:
title: 简单快速地发送一条消息
description: 简单快速地发送一条消息
input:
bootstrap_servers:
title:
en: Bootstrap_servers
zh-CN: 服务器列表
type: "[]string"
description:
en: Server list, e.g ["127.0.0.1:9092","127.0.0.2:9092"]
zh-CN: 服务器列表，例如 ["127.0.0.1:9092","127.0.0.2:9092"]
required: true
default:
- 172.36.0.1:9092
topic:
title:
en: Topic
zh-CN: 主题
type: string
description:
en: The theme
zh-CN: 主题
required: true
msg:
title:
en: Message
zh-CN: 消息
type: string
required: true
default: Hello
output:
log:
title:
en: Log
zh-CN: 日志
type: string
description:
en: Whether the message was sent successfully
zh-CN: 消息是否发送成功
required: true