MQTT 插件开发示例 常量说明 第一步，指令处理层开发 第二步，应用层开发 .open .close .init .uninit .start .stop .setting .request 第三步，插件设置文件 MQTT 插件开发示例 北向应用开发主要包含以下几个部分，最底层的是指令处理层开发，最外层的是应用层开发。 模块...

消费者示例 1 Consumer 示例 1.1 PullConsumer 1.2 PushConsumer 消费者示例 1 Consumer 示例 TubeMQ 提供了两种方式来消费消息： PullConsumer and PushConsumer。 1.1 PullConsumer public class PullConsume...

MySQL 到 StarRocks 示例 环境部署 安装 InLong 添加 Connectors 安装 StarRocks 集群初始化 创建集群标签 注册 Pulsar 集群 注册 StarRocks 数据节点 任务创建 新建数据流组 创建数据源 创建数据目标 审批数据流 测试数据 发送数据 验证数据 MySQL 到 ...

安全策略示例 背景 每个主机需要不同的 JWT 签名者 命名空间隔离 将 Ingress 排除在外的命名空间隔离 要求在鉴权层使用 mTLS（深度防御） 使用 DENY 策略时要求强制的鉴权检查 安全策略示例 背景 本页展示了使用 Istio 安全策略的通用模式。 您可能发现这些模式在部署时很有用，还可以将其用作策略示例的快速参考。 ...

生产者示例 1 Producer 示例 1.1 TubeSingleSessionFactory 1.1.1 Send Message Synchronously 1.1.2 Send Message Asynchronously 1.1.3 Send Message With Attributes 1.2 TubeMultiSessionFacto...

生产者示例 1 Producer 示例 1.1 TubeSingleSessionFactory 1.1.1 Send Message Synchronously 1.1.2 Send Message Asynchronously 1.1.3 Send Message With Attributes 1.2 TubeMultiSessionFacto...

消费者示例 1 Consumer 示例 1.1 PullConsumer 1.2 PushConsumer 消费者示例 1 Consumer 示例 TubeMQ 提供了两种方式来消费消息： PullConsumer and PushConsumer。 1.1 PullConsumer public class PullConsume...

生产者示例 1 Producer 示例 1.1 TubeSingleSessionFactory 1.1.1 Send Message Synchronously 1.1.2 Send Message Asynchronously 1.1.3 Send Message With Attributes 1.2 TubeMultiSessionFacto...