Kafka 消费组

    搭建 Kafka 环境，以 MacOS X 为例:

    提示

    Kafka 消费组不支持 Kafka0.9 以下版本

    创建资源之前，需要提前创建 Kafka 主题，不然会提示错误

    创建 Kafka 的主题:

    选择 Kafka 消费组模块:

    img

    填写相关参数:

    • Kafka 服务器地址
    • Kafka consumer 连接池大小
    • MQTT 的消息主题
    • MQTT 的主题服务质量
    • MQTT PayLoad，可选使用 Kafka message.value 或者 message 全部信息
    • 二进制 value 编码模式，UTF-8 或 base64，消息中 value 的编码方式，如果 value 值为非字符串或可能产生字符集编码异常的值，推荐使用 base64 模式
    • Kafka Max Bytes (每次从 Kafka 里消费消息的最大字节数)
    • Kafka Offset Reset Policy (重置Offset策略,reset_to_latest | reset_by_subdcriber)
    • SSL 连接参数

    img

    资源已经创建完成，现在用Dashboard的websocket工具订阅MQTT的主题 “TestTopic”:

    使用kafka 命令行 生产一条消息:

    img