issues
search
flier
/
tokio-kafka
Asynchronous Rust client for Apache Kafka
Apache License 2.0
31
stars
1
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
Leave consumer group on timer & unknown heartbeat errors
#34
polachok
opened
6 years ago
0
ConsumerBuilder: add with_error_backoff() and with_fetch_min_bytes()
#33
polachok
closed
6 years ago
0
Support record format v2
#32
flier
opened
6 years ago
0
Prefetch record base on low/high watermark
#31
flier
opened
6 years ago
3
Producer::flush() blocks forever
#30
polachok
opened
6 years ago
0
Prefetch
#29
polachok
opened
6 years ago
3
Use existing assignment if found
#28
polachok
closed
6 years ago
1
Always seek
#27
polachok
closed
6 years ago
0
Add with_fetch_max_bytes/with_partition_max_bytes
#26
polachok
closed
6 years ago
1
OffsetFetch max version is 1
#25
polachok
closed
6 years ago
2
OffsetCommit is supported up to v2
#24
polachok
closed
6 years ago
1
Better report thunk errors
#23
polachok
closed
6 years ago
1
Fix heartbeat error handling
#22
polachok
closed
6 years ago
1
Producer builder add max_request_size
#21
polachok
closed
6 years ago
1
Offsets from coordinator
#20
polachok
closed
6 years ago
2
ConsumerRecord offset was set to latest for all messages
#19
polachok
closed
6 years ago
1
Getting below compilaton error
#18
surajprak
closed
6 years ago
3
How do install this library locally
#17
surajprak
closed
6 years ago
2
Consumer: offset is not reset on OutOfRange
#16
polachok
opened
6 years ago
0
Fix api versions
#15
polachok
closed
6 years ago
2
Consumer: how to commit offsets?
#14
polachok
opened
6 years ago
3
Replace GetMetadata with a custom future implementation
#13
polachok
closed
6 years ago
1
Compression: snappy compression
#12
polachok
closed
6 years ago
5
Fix 'already borrowed' panic in fetcher
#11
polachok
closed
6 years ago
1
Add Consumer builder option auto_offset_reset
#10
polachok
closed
6 years ago
1
message: RECORD_HEADER_SIZE is wrong
#9
polachok
closed
6 years ago
1
message: RECORD_HEADER_SIZE is wrong
#8
polachok
closed
6 years ago
1
network/codec: reserve space for length marker before put
#7
polachok
closed
6 years ago
0
Remove tokio-middleware dependency
#6
polachok
closed
6 years ago
1
Fix version serializer
#5
polachok
closed
6 years ago
1
Is this library maintained?
#4
polachok
opened
6 years ago
4
Not able to find crate entry for tokio-kafka
#3
surajprak
opened
6 years ago
5
Need to take data from a channel receiver and produce it to kafka
#2
surajprak
opened
6 years ago
0
Consider adding a very short README with status of the project
#1
kamalmarhubi
closed
6 years ago
3