Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / tx7do/kratos-transport issues and pull requests

#112 - 关于websocket 使用json

Issue - State: closed - Opened by lugcz about 1 month ago - 1 comment

#111 - 注册Asynq服务到nacos报错

Issue - State: closed - Opened by lugcz 2 months ago - 8 comments

#109 - Improve the configuration items of asynq Scheduler

Pull Request - State: closed - Opened by lenuse 2 months ago

#108 - fix nil pointer panic

Pull Request - State: closed - Opened by cyberxnomad 3 months ago

#107 - utils 重命名为 keepalive 后，需要给 transport 升一下 tag

Issue - State: closed - Opened by cyberxnomad 3 months ago - 3 comments

#106 - websocket 如何取得query param

Issue - State: closed - Opened by lugcz 3 months ago - 1 comment

#105 - add kafka middleware

Pull Request - State: closed - Opened by lenuse 3 months ago

#104 - 使用kratos注册到consul中后服务发现报错

Issue - State: open - Opened by an15221315127 4 months ago - 6 comments

#103 - Broker如kafka可以支持批量消费吗

Issue - State: open - Opened by kimloong 4 months ago

#101 - redis重启以后订阅主题没有自动恢复

Issue - State: open - Opened by fredmuyu 5 months ago

#98 - fix(transport/machinery): ignore graceful exit error

Pull Request - State: closed - Opened by hominsu 6 months ago

#97 - Request-Reply for Nats

Pull Request - State: closed - Opened by azyoskol 6 months ago

#96 - fix kafka subscriber EOF log when closing program

Pull Request - State: closed - Opened by dgqypl 7 months ago

#94 - RocketMQ的消费者组只能配置一个吗？可以配置多个吗？

Issue - State: closed - Opened by mirror6Y 7 months ago - 1 comment

#93 - fix: fetch message on eof return

Pull Request - State: closed - Opened by fzdwx 7 months ago

#92 - 能否支持多brokers

Issue - State: closed - Opened by mambaji 8 months ago - 2 comments

#91 - 建议开放自定义Tcp 消息解析。

Issue - State: open - Opened by kissIce 8 months ago - 1 comment

#89 - broker/kafka v1.2.6 以后 kafka consumer 不消费数据了

Issue - State: closed - Opened by dgqypl 8 months ago - 3 comments

#88 - 项目使用 transport/kafka v1.2.10 会编译失败

Issue - State: closed - Opened by dgqypl 8 months ago - 2 comments

#87 - fix kafka broker Completion not working problem

Pull Request - State: closed - Opened by dgqypl 9 months ago

#86 - 异步写 kafka 设置回调函数没生效

Issue - State: closed - Opened by dgqypl 9 months ago - 2 comments

#84 - kafka message add partition and offset

Pull Request - State: closed - Opened by xichengliudui 9 months ago

#84 - kafka message add partition and offset

Pull Request - State: closed - Opened by xichengliudui 9 months ago

#83 - Update options.go

Pull Request - State: closed - Opened by sleep-go 9 months ago

#83 - Update options.go

Pull Request - State: closed - Opened by sleep-go 9 months ago

#82 - feat: add register function with context

Pull Request - State: closed - Opened by Slone123c 9 months ago

#82 - feat: add register function with context

Pull Request - State: closed - Opened by Slone123c 9 months ago

#81 - 异步写 kafka 可否把函数也放到 WriterConfig 中？

Issue - State: closed - Opened by dgqypl 9 months ago - 1 comment

#81 - 异步写 kafka 可否把函数也放到 WriterConfig 中？

Issue - State: closed - Opened by dgqypl 9 months ago - 1 comment

#80 - feat: support task waiting for results

Pull Request - State: closed - Opened by Madou-Shinni 9 months ago - 1 comment

#80 - feat: support task waiting for results

Pull Request - State: closed - Opened by Madou-Shinni 9 months ago - 1 comment

#79 - fix kafka done check

Pull Request - State: closed - Opened by haifeiWu 10 months ago

#76 - fix kafka done check

Pull Request - State: closed - Opened by haifeiWu about 1 year ago

#75 - FR: `kafka.Server` 添加一个 option 进来，传入 `broker.Broker`

Issue - State: closed - Opened by fzdwx about 1 year ago - 3 comments

#74 - Asynq服务支持配置 config 和 定义不减少重试次数的错误

Pull Request - State: closed - Opened by Slone123c about 1 year ago

#73 - redis 链接哨兵集群

Issue - State: closed - Opened by hhmy27 about 1 year ago

#72 - 死锁

Issue - State: closed - Opened by cuijianguo about 1 year ago - 2 comments

#70 - endpoint 实现逻辑是否有问题

Issue - State: closed - Opened by zoulux about 1 year ago

#69 - kafka 订阅通配符主题报错

Issue - State: closed - Opened by fredmuyu about 1 year ago - 3 comments

#68 - 从1.0.12升级到1.1.1 直接失败

Issue - State: closed - Opened by fredmuyu about 1 year ago - 2 comments

#67 - body support json

Pull Request - State: closed - Opened by samsaralc about 1 year ago

#66 - [bug] rabbitmq reconnect 时候，publish消息失败

Issue - State: open - Opened by Davidzkeng about 1 year ago - 3 comments

#65 - fix: 修复了 transport/kafka 编译报错的问题

Pull Request - State: closed - Opened by qiulin about 1 year ago

#64 - transport/kafka v1.2.3 打包报错

Issue - State: closed - Opened by qiulin about 1 year ago

#63 - rocketmq 订阅不能使用广播模式

Issue - State: closed - Opened by duke123abc about 1 year ago - 4 comments

#62 - createProducer 鉴权问题

Issue - State: closed - Opened by ruan875417 about 1 year ago - 1 comment

#61 - 会给nats加入jetstream么？

Issue - State: open - Opened by shaohongwu over 1 year ago - 1 comment

#60 - 子包无法通过 go get -u 升级

Issue - State: closed - Opened by withrjp over 1 year ago - 1 comment

#60 - 子包无法通过 go get -u 升级

Issue - State: closed - Opened by withrjp over 1 year ago - 1 comment

#59 - pulsar 的 keepAlive 有问题？

Issue - State: closed - Opened by moecasts over 1 year ago - 4 comments

#58 - pulsar 的可以支持 kratos 2.7 吗？

Issue - State: closed - Opened by moecasts over 1 year ago - 4 comments

#57 - MQTT断线后重连，订阅消息无法恢复

Issue - State: closed - Opened by happychenleilei over 1 year ago

#56 - 关于子模块go依赖包版本号问题

Issue - State: closed - Opened by code-tbd over 1 year ago - 1 comment

#55 - 关于websocket模块handler函数传递参数的问题

Issue - State: closed - Opened by code-tbd over 1 year ago - 1 comment

#54 - rabbitmq存在方法未实现

Issue - State: closed - Opened by zhongy-web over 1 year ago - 7 comments

#52 - cannot use tr.reqHeader问题，求解决

Issue - State: closed - Opened by Invercargill over 1 year ago - 2 comments

#51 - 考虑支持RocketMQ5.x

Issue - State: closed - Opened by shanezhiu over 1 year ago - 6 comments

#50 - feat: support websocket text message

Pull Request - State: closed - Opened by sohenk over 1 year ago

#49 - hotfix: mqtt test subscribe error without context

Pull Request - State: closed - Opened by chadlwm over 1 year ago

#48 - 缝合怪

Issue - State: closed - Opened by mjczz over 1 year ago - 1 comment

#47 - 如何根据userId的hash值将数据发送到指定的分区呢

Issue - State: closed - Opened by Wanghongw over 1 year ago - 13 comments

#46 - go mod tidy的默认版本参数类型不对

Issue - State: closed - Opened by mpraiser over 1 year ago - 1 comment

#45 - kratos版本不一致 tr.reqHeader 报错

Issue - State: closed - Opened by shaohongwu over 1 year ago - 1 comment

#44 - fix(broker nats): 修复nats broker订阅者解码proto协议失败问题

Pull Request - State: closed - Opened by xiongpan828 almost 2 years ago - 1 comment

#43 - mqtt不支持qos配置

Issue - State: closed - Opened by aide-cloud about 2 years ago - 1 comment

#42 - 支持comfirm和return模式确保消息不丢失吗

Issue - State: open - Opened by azhu0914 about 2 years ago

#41 - kitex支持

Issue - State: closed - Opened by godsoul about 2 years ago - 2 comments

#40 - 使用 rabbitmq server 遇到的queue消费不了的问题

Issue - State: closed - Opened by rxrddd about 2 years ago - 1 comment

#39 - mqtt 如何获取原始数据 mq.Payload()

Issue - State: closed - Opened by FxStar about 2 years ago

#37 - 和Kratos适配时，优雅关闭问题。

Issue - State: closed - Opened by chazex about 2 years ago - 3 comments

#36 - 在kafka server中，如何指定kafka-go的reader的QueueCapacity参数

Issue - State: closed - Opened by chazex about 2 years ago - 1 comment

#35 - mqtt断线重连没有处理订阅

Issue - State: closed - Opened by chinamty about 2 years ago

#34 - feat: kafka borker with logger

Pull Request - State: closed - Opened by exuan about 2 years ago

#33 - fix: when kafka restart, it does not consume message

Pull Request - State: closed - Opened by exuan about 2 years ago

#30 - kafka trace 集成到kratos中没有生效

Issue - State: closed - Opened by lswencn about 2 years ago - 3 comments

#27 - redis conn error

Issue - State: closed - Opened by ckall over 2 years ago

#26 - kafka 重启之后，没有重新订阅消息

Issue - State: closed - Opened by exuan over 2 years ago

#25 - [fix]fix asynq issue #23 & #24

Pull Request - State: closed - Opened by aegoens over 2 years ago

#24 - [BUG]Could`t apply Options to asynq.Server

Issue - State: closed - Opened by aegoens over 2 years ago

#23 - [BUG] runAsynqServer function mistakenly assert server is nil

Issue - State: closed - Opened by aegoens over 2 years ago

#22 - 是否支持nats jetstream？

Issue - State: closed - Opened by leyou240 over 2 years ago - 2 comments

#21 - fix: subscriber.ch isn't closed in the event of unexpected disconnection.

Pull Request - State: closed - Opened by ryan961 over 2 years ago

#19 - fix: fix rabbitmq tracer cannot be concatenated, context error #18

Pull Request - State: closed - Opened by shuqingzai over 2 years ago