issues
search
ego-component
/
ekafka
ekafka,kafka,ego
MIT License
7
stars
5
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
fix: consumerserver example 中处理订阅错误
#20
jackcipher
closed
2 months ago
0
当kafka服务断掉再启动后，ekafka无法自动连接
#19
songkaiha
opened
3 months ago
5
upgrade github.com/segmentio/kafka-go
#18
askuy
closed
4 months ago
0
fix batch handler timeout
#17
clannadxr
closed
5 months ago
0
set default debug to false
#16
sevennt
closed
10 months ago
0
newBatchListener auto commit
#15
sevennt
closed
10 months ago
0
fix sasl panic
#14
clannadxr
closed
10 months ago
0
Feat poll add ctx
#13
clannadxr
closed
10 months ago
0
kafka compress
#12
qingbozhang
closed
1 year ago
0
batch handler 消息里加上ctx
#11
clannadxr
closed
1 year ago
0
不暴露NewListener
#10
clannadxr
closed
1 year ago
0
support batch listener
#9
clannadxr
closed
1 year ago
0
support batch listener
#8
clannadxr
closed
1 year ago
0
consumer 退出时继续提交未提交的消息
#7
clannadxr
closed
1 year ago
0
kafka handler 里 message 改成指针
#6
clannadxr
closed
1 year ago
0
add topic to accessClientInterceptor
#5
sevennt
closed
1 year ago
0
remove consumptionErrors
#4
clannadxr
closed
1 year ago
0
支持不提交消息 & kafka 错误时，不退出 consumer server
#3
clannadxr
closed
1 year ago
0
feat: 同步gotomicro ekafka变更
#2
kl7sn
closed
1 year ago
0
feat: 支持tls证书加载
#1
kl7sn
closed
1 year ago
1