folkmq
folkmq copied to clipboard
作一个体验最简单的消息中间件。支持Qos0、定时、过期、顺序、广播、事务、二进制等消息特性。有确认、重试、延时等机制。可嵌入、单机、集群等部署。
语法建议rabbitmq和mqtt都兼容 rabbitmq以.作为分隔符,#作为多层级通配符,*作为单层级通配符 mqtt以/作为分隔符,#作为多层级通配符,+作为单层级通配符 建议两种都兼容
欢迎尝试 folkmq-pro 模块下,已添加类:MqWatcherMetrics
`org.noear.socketd.transport.client.Client#open` 以及 `openOrThrow` 函数, 其签名感觉可以改成 ` T open();` 以规避强转这种感觉不优雅的情况?
软件版本:1.7.9 版本 系统版本:ubuntu20.04 运行环境:单机运行 根据官网执行服务端启动:sudo docker run -p 18602:18602 -p 8602:8602 -e folkmq.admin='admin' 7b3eed707d9a 然后启动python客户端进行测试,python _msg.py,总是报上面这个错误,找不到解决办法  
像kafka那样,从指定位置(从头开始,从最新消息开始)消费要怎么配置呢?