issues
search
doujiang24
/
lua-resty-kafka
Lua kafka client driver for the Openresty based on the cosocket API
BSD 3-Clause "New" or "Revised" License
801
stars
274
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Propagate SASL auth config to other brokers
#115
samcrawford
closed
2 years ago
0
Producer cannot send with Confluent Cloud due to SASL error
#114
samcrawford
closed
2 years ago
3
Resolver issues, not solved?
#113
ghost
opened
2 years ago
1
Chores/change method scope
#112
artomal
closed
2 years ago
0
Broker list doesn't refresh
#111
hamishforbes
opened
3 years ago
3
consumer
#110
ltanme
opened
3 years ago
0
some msg lose with error buffered messages send to kafka err: not found topic
#109
dean-river
opened
3 years ago
0
Avro Support
#108
danaspice
opened
3 years ago
0
在正常运行了一段时间后,在执行producer:send会出现
#107
282857484
opened
3 years ago
1
当前项目存在的问题
#106
lsasta
opened
3 years ago
2
当在producer中设置required_acks为0的时候,会出现timeout异常【when set required_acks=0 in producer, it will throw 'producer.lua:272: buffered messages send to kafka err: timeout'】
#105
kxbin
closed
3 years ago
3
update travis.yml zookeeper version to 3.5.8
#104
zz123er
closed
2 years ago
1
feature: 1.ssl re use support
#103
zz123er
closed
2 years ago
1
[WIP] feature: 1.sasl auth support
#102
zz123er
closed
2 years ago
6
buffered messages send to kafka err: no resolver defined to resolve "cdh-1", retryable: true
#101
lsasta
opened
3 years ago
0
发送数据到kafka最终只落地到一个分区,查了下是因为每次有新的请求过来,correlation_id再次被初始化,这个问题有遇到吗?
#100
TomZou
closed
3 years ago
4
Is there a way to authenticate with SSL certs?
#99
alekseyp
opened
3 years ago
8
Configurable host name resolving
#98
alyoshark
closed
2 years ago
11
_fetch_metadata(): broker fetch metadata failed, err:timeout
#97
lerpo
opened
4 years ago
2
formatting of client error message
#96
kikito
closed
4 years ago
1
batch mode for sync mode
#95
bdfy
closed
4 years ago
1
What does this error mean: err: not found broker ?
#94
jeremyjpj0916
opened
4 years ago
3
What does this error mean?
#93
jeremyjpj0916
closed
4 years ago
0
nginx restart, reload, stop start会丢失数据吗?
#92
sugue
closed
4 years ago
1
Add TLS support to kafka broker connections
#91
jeremyjpj0916
closed
4 years ago
18
是否可以支持sasl鉴权?
#90
sugue
opened
4 years ago
1
每次访问都报这个错?
#89
King2Jack
closed
4 years ago
1
create timer_every = ngx.timer.every failed, the value is nil
#88
wm045631
closed
4 years ago
2
fix the zookeeper version.
#87
Akayeshmantha
closed
4 years ago
0
producer.lua:354: attempt to call upvalue 'timer_every' (a nil value)
#86
Simon0910
closed
4 years ago
6
Create a tag with latest commit
#85
starsz
closed
4 years ago
3
add travis ci support
#84
wanghuizzz
closed
4 years ago
1
fix too many pending timers with timer.every
#83
wanghuizzz
closed
4 years ago
1
Fix bug about str_int64 and add protect
#82
anhzhi
opened
4 years ago
2
任意一台broker挂了,整个消息就发送失败了?
#81
mocking3
opened
4 years ago
5
added rockspec
#80
kikito
closed
4 years ago
2
flush_time,batch_size Settings don't work
#79
caojingfu1990
opened
5 years ago
1
producer.lua:258: buffered messages send to kafka err: not found topic, retryable: true, topic: alanwalk, partition_id: -1, length: 1
#78
hgaong
closed
5 years ago
12
send() failed (111: Connection refused) while resolving, resolver: 127.0.0.1:53
#77
15537261738
opened
5 years ago
0
openresty-lua and kafka server BufferOverflow error
#76
dev-omniwyse
opened
5 years ago
2
即使是在异常情况下,为什么producer:send返回的都是true呢
#75
wangzili064
closed
5 years ago
9
Is this repository still maintained?
#74
subnetmarco
opened
5 years ago
2
fix(producer) too many timer
#73
mengskysama
closed
4 years ago
4
when requiring module getting error
#72
csvisakh7
opened
5 years ago
0
Could you realize the Comsumer?
#71
chenweijing
opened
5 years ago
0
kafka is down , lua kafka product send err, nginx must be reload manually
#70
zouliqiang
opened
5 years ago
1
No timestamp supported?
#69
echovalley
opened
5 years ago
1
producer.lua:258: buffered messages send to kafka err: no resolver defined to resolve ip
#68
sstong123
closed
6 years ago
2
send() failed (104: Connection reset by peer), context: ngx.timer, client: 10.150.50.235, server: 0.0.0.0:80
#67
sstong123
opened
6 years ago
2
producer.lua:284: _flush_buffer(): failed to create timer at _flush_buffer, err: too many pending timers
#66
sstong123
closed
6 years ago
8
Previous
Next