转换器

1. 转换器定义

转换器与连接器是类似的功能，不同的是，转换器是消息传递的生成者，而连接器是消息传递的消费者

转换器支持的类型

• KAFKA
• ROCKET-MQ
• RIBBIT-MQ

2. 转换器创建

Kafka转换器

• 进入 MQTT Dashboard，并点击 集成 -> 转换器，点击页面右上角的 创建

• 在创建转换器页面中，选择 Kafka 服务，然后点击 前进。

• 配置kafka参数

  转换器名称

  broker，填写kafka服务器IP地址 如 localhost:9092

  消费实例数，即是kafka消费者的实例，默认是10个消费实例

  其他参数尽量不更改

• 测试连接，参数是否正确。点击创建。

rabbitmq转换器

• 进入 MQTT Dashboard，并点击 集成 -> 转换器，点击页面右上角的 创建

• 在创建转换器页面中，选择 rabbitmq 服务，然后点击 前进。

• 配置rabbitmq参数

  转换器名称

  连接主机，填写rabbitmq服务器IP地址 如 localhost

  连接端口，rabbitmq服务端口，默认5762

  虚拟主机，rabbitmq的虚拟机

  用户名&密码，rabbitmq连接的账号密码

• 测试连接，参数是否正确。点击创建。

rocketmq转换器

• 进入 MQTT Dashboard，并点击 集成 -> 转换器，点击页面右上角的 创建

• 在创建转换器页面中，选择 rocketmq 服务，然后点击 前进。

• 配置rocketmq参数

  转换器名称

  生产者组，rocketmq定义的队列组

  服务地址，rocketmq服务地址，默认127.0.0.1:9876

  实例名称，rocketmq实例名称

• 测试连接，参数是否正确。点击创建