在开启ZMQ网关后,配置了zmq_sub_pre和zmq_pub_pre时,zmq使用send_multipart发送复合消息,nanomq接受到了2条消息,把2条消息拆开了,导致进入ekuiper时,将前面的topic消息也进行了pb的处理导致报错,但是不影响后续消息解析,这个机制是这样还是有问题呢?
是的,这里的机制就是这样的,目前都是一条一条发的。
zeromq来的消息就是分开的
在开启ZMQ网关后,配置了zmq_sub_pre和zmq_pub_pre时,zmq使用send_multipart发送复合消息,nanomq接受到了2条消息,把2条消息拆开了,导致进入ekuiper时,将前面的topic消息也进行了pb的处理导致报错,但是不影响后续消息解析,这个机制是这样还是有问题呢?
是的,这里的机制就是这样的,目前都是一条一条发的。
zeromq来的消息就是分开的