issues
search
tx7do
/
kratos-transport
kratos transport layer extension
MIT License
336
stars
91
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
rocketmq client v2情况下，消费消息失败不会再次消费
#99
gavinliu4011
opened
1 day ago
0
fix(transport/machinery): ignore graceful exit error
#98
hominsu
opened
3 weeks ago
0
Request-Reply for Nats
#97
azyoskol
closed
1 month ago
0
fix kafka subscriber EOF log when closing program
#96
dgqypl
closed
1 month ago
0
使用nacos作为注册中心时，启动带有rabbitmq服务的server会报错
#95
lgcshy
closed
1 month ago
2
RocketMQ的消费者组只能配置一个吗？可以配置多个吗？
#94
mirror6Y
closed
6 days ago
1
fix: fetch message on eof return
#93
fzdwx
closed
1 month ago
0
能否支持多brokers
#92
mambaji
closed
2 months ago
2
建议开放自定义Tcp 消息解析。
#91
kissIce
opened
2 months ago
1
asynq 怎么把service 注入到 server, 如果执行到handler 怎么用service、data 的方法？
#90
zhouyg
closed
3 months ago
1
broker/kafka v1.2.6 以后 kafka consumer 不消费数据了
#89
dgqypl
closed
3 months ago
3
项目使用 transport/kafka v1.2.10 会编译失败
#88
dgqypl
closed
3 months ago
2
fix kafka broker Completion not working problem
#87
dgqypl
closed
3 months ago
0
异步写 kafka 设置回调函数没生效
#86
dgqypl
closed
3 months ago
2
1.2.10版本 Subscribe时Message结构体中没有分区和偏移量，但是设置时存在
#85
PHP-liuxiong
closed
3 months ago
1
kafka message add partition and offset
#84
xichengliudui
closed
3 months ago
0
Update options.go
#83
sleep-go
closed
3 months ago
0
feat: add register function with context
#82
Slone123c
closed
3 months ago
0
异步写 kafka 可否把函数也放到 WriterConfig 中？
#81
dgqypl
closed
3 months ago
1
feat: support task waiting for results
#80
Madou-Shinni
closed
4 months ago
1
fix kafka done check
#79
haifeiWu
closed
4 months ago
0
fix: 修复 `aliyunmq` 和 `rocketmq-client-go` 消息 handler error 的处理
#78
sunznx
closed
5 months ago
0
为什么 Rocketmq 的 3 个 broker 对 `AutoAck` 的处理不一样
#77
sunznx
closed
5 months ago
0
fix kafka done check
#76
haifeiWu
closed
7 months ago
0
FR: `kafka.Server` 添加一个 option 进来，传入 `broker.Broker`
#75
fzdwx
closed
7 months ago
3
Asynq服务支持配置 config 和 定义不减少重试次数的错误
#74
Slone123c
closed
7 months ago
0
redis 链接哨兵集群
#73
hhmy27
closed
7 months ago
0
死锁
#72
cuijianguo
closed
5 months ago
2
fix: 修复 KeepAliveService host 为空的问题，通过环境变量注入网卡数据自动获取 ip
#71
zoulux
closed
8 months ago
0
endpoint 实现逻辑是否有问题
#70
zoulux
closed
5 months ago
0
kafka 订阅通配符主题报错
#69
fredmuyu
closed
3 months ago
3
从1.0.12升级到1.1.1 直接失败
#68
fredmuyu
closed
8 months ago
2
body support json
#67
samsaralc
closed
8 months ago
0
[bug] rabbitmq reconnect 时候，publish消息失败
#66
Davidzkeng
opened
8 months ago
3
fix: 修复了 transport/kafka 编译报错的问题
#65
qiulin
closed
9 months ago
0
transport/kafka v1.2.3 打包报错
#64
qiulin
closed
8 months ago
0
rocketmq 订阅不能使用广播模式
#63
duke123abc
closed
9 months ago
4
createProducer 鉴权问题
#62
ruan875417
closed
9 months ago
1
会给nats加入jetstream么？
#61
shaohongwu
opened
10 months ago
1
子包无法通过 go get -u 升级
#60
withrjp
closed
10 months ago
1
pulsar 的 keepAlive 有问题？
#59
moecasts
closed
11 months ago
4
pulsar 的可以支持 kratos 2.7 吗？
#58
moecasts
closed
11 months ago
4
MQTT断线后重连，订阅消息无法恢复
#57
happychenleilei
closed
12 months ago
0
关于子模块go依赖包版本号问题
#56
tbdrm
closed
10 months ago
1
关于websocket模块handler函数传递参数的问题
#55
tbdrm
closed
1 year ago
1
rabbitmq存在方法未实现
#54
zhongy-web
closed
1 year ago
7
kafka是否可以支持像NSQ那样WithDeferredPublish的配置，实现延迟队列呢？
#53
Wanghongw
closed
12 months ago
1
cannot use tr.reqHeader问题，求解决
#52
Invercargill
closed
1 year ago
2
考虑支持RocketMQ5.x
#51
shanezhiu
closed
10 months ago
6
feat: support websocket text message
#50
sohenk
closed
12 months ago
0
Next