GitHub / kafka-rust/kafka-rust issues and pull requests
#247 - Fetch group offset: failed to fill whole buffer
Issue -
State: open - Opened by liuxuzxx 5 months ago
#246 - feat: Added the support for the new format of producer message with timestamp support
Pull Request -
State: open - Opened by yra1029 8 months ago
#246 - feat: Added the support for the new format of producer message with timestamp support
Pull Request -
State: open - Opened by yra1029 8 months ago
#245 - authentication features
Issue -
State: open - Opened by ManuelSopenaBallesteros 9 months ago
#243 - Write a test for seek function.
Issue -
State: open - Opened by johnward 9 months ago
#242 - feat: trying to implement rustls
Pull Request -
State: closed - Opened by oneslash 10 months ago
#241 - bump crate versions
Pull Request -
State: open - Opened by ByteBaker 12 months ago
#241 - bump crate versions
Pull Request -
State: open - Opened by ByteBaker 12 months ago
- 1 comment
#240 - [Request] - Feature parity comparison with `rdkafka`
Issue -
State: open - Opened by theelderbeever 12 months ago
#239 - Need to fix the Docker login
Issue -
State: open - Opened by johnward about 1 year ago
#238 - Add CI, Make tests work, Deprecate EOL releases, Update Deps
Pull Request -
State: closed - Opened by oneslash about 1 year ago
- 1 comment
#238 - Add CI, Make tests work, Deprecate EOL releases, Update Deps
Pull Request -
State: closed - Opened by oneslash about 1 year ago
- 3 comments
#237 - Use rustl instead of openssl
Issue -
State: open - Opened by Omega359 about 1 year ago
#236 - Add CI, Make tests work, Deprecate EOL releases, Update Deps
Pull Request -
State: closed - Opened by oneslash about 1 year ago
- 2 comments
#236 - Add CI, Make tests work, Deprecate EOL releases, Update Deps
Pull Request -
State: closed - Opened by oneslash about 1 year ago
- 3 comments
#235 - CI update and drop old versions
Issue -
State: open - Opened by oneslash about 1 year ago
#234 - Message timestamp
Issue -
State: open - Opened by kalimalrazif about 1 year ago
#233 - refactor: fix clippy lints
Pull Request -
State: closed - Opened by ByteBaker over 1 year ago
- 2 comments
#233 - refactor: fix clippy lints
Pull Request -
State: closed - Opened by ByteBaker over 1 year ago
- 1 comment
#232 - How to connect using credentials, like username and password?
Issue -
State: open - Opened by AliElMoussawi over 1 year ago
#231 - Two consumers can receive the same message with same group and topic
Issue -
State: open - Opened by Xu-Mj over 1 year ago
#230 - how to create and delete topic with kafka-rust
Issue -
State: open - Opened by Jungle666 over 1 year ago
#229 - See message headers
Issue -
State: open - Opened by conradogarciaberrotaran over 1 year ago
- 2 comments
#228 - UnknowTopicOrPartitiion Error
Issue -
State: open - Opened by vizvasrj over 1 year ago
#227 - doc(README.md): Send the request to the broker instead of zookeeper
Pull Request -
State: closed - Opened by hkairi almost 2 years ago
#227 - doc(README.md): Send the request to the broker instead of zookeeper
Issue -
State: closed - Opened by hkairi almost 2 years ago
#226 - Consume from Latest
Issue -
State: open - Opened by evanzhang87 almost 2 years ago
#225 - commit_consumed RequestTimedOut
Issue -
State: open - Opened by evanzhang87 almost 2 years ago
#224 - Failed to debug from VSCode after added kafka client references. ("Unknown error (Open 'launch.json'" when F5)
Issue -
State: open - Opened by normanlmfung almost 2 years ago
#223 - list offsets
Pull Request -
State: closed - Opened by YilunAllenChen about 2 years ago
- 1 comment
#223 - list offsets
Pull Request -
State: closed - Opened by YilunAllenChen about 2 years ago
- 1 comment
#222 - seek
Pull Request -
State: closed - Opened by YilunAllenChen about 2 years ago
- 2 comments
#222 - seek
Pull Request -
State: closed - Opened by YilunAllenChen about 2 years ago
#221 - list offsets
Pull Request -
State: closed - Opened by YilunAllenChen about 2 years ago
- 1 comment
#220 - docs: fix comments in `src/consumer/mod.rs`
Pull Request -
State: closed - Opened by hamirmahal over 2 years ago
#219 - is this repo being maintained?
Issue -
State: closed - Opened by ravieze over 2 years ago
- 6 comments
#218 - How to get the offset of the last message in a partition?
Issue -
State: open - Opened by ravieze over 2 years ago
#217 - TLS max record size
Issue -
State: open - Opened by bellefab over 2 years ago
#216 - docs: Fix grammar mistakes in README.md
Pull Request -
State: closed - Opened by joshua-mo-143 almost 3 years ago
- 1 comment
#215 - Add missing spaces in the README
Pull Request -
State: closed - Opened by aaabramov almost 3 years ago
#214 - Version 0.9
Issue -
State: open - Opened by Raawaan about 3 years ago
- 2 comments
#213 - switched to API v1 for most messages, v2 for fetch requests to support timestamps
Pull Request -
State: open - Opened by ilya-epifanov about 3 years ago
- 1 comment
#212 - Sending message with headers
Issue -
State: open - Opened by mesuutt about 3 years ago
- 2 comments
#211 - Consumers of the same group consuming same partitions and getting same messages
Issue -
State: open - Opened by juliorenner about 3 years ago
- 2 comments
#210 - How to get message timestamp
Issue -
State: open - Opened by Mrzrb over 3 years ago
- 2 comments
#209 - Formatting, dependency upgrade, and some niceties
Pull Request -
State: closed - Opened by midnightexigent over 3 years ago
- 1 comment
#208 - Protocol Rework
Pull Request -
State: open - Opened by midnightexigent over 3 years ago
#207 - Addition of upstash sponsorship
Pull Request -
State: closed - Opened by johnward over 3 years ago
- 1 comment
#206 - Added Kafka 3.1.0 to integration tests and changed misc error handling
Pull Request -
State: closed - Opened by r3h0 over 3 years ago
- 2 comments
#205 - [Feature] Versions handling
Issue -
State: open - Opened by Dzordzu over 3 years ago
- 8 comments
#204 - [Feature request] Support for rebalancing and heartbeat
Issue -
State: open - Opened by Dzordzu over 3 years ago
- 8 comments
#203 - Depency upgrade & Minor refactorings
Pull Request -
State: closed - Opened by midnightexigent over 3 years ago
- 1 comment
#202 - v0.8.0 is pointing to error-chain = "0.10" that is creating an error
Issue -
State: closed - Opened by rodoufu about 4 years ago
- 3 comments
#201 - bump deps
Pull Request -
State: closed - Opened by tshepang about 4 years ago
#200 - use automatic tooling to modernise codebase
Pull Request -
State: closed - Opened by tshepang about 4 years ago
- 4 comments
#199 - "for ms in consumer.poll().unwrap().iter()" produces temporary value error
Issue -
State: closed - Opened by sempervictus over 4 years ago
- 3 comments
#198 - windows-gnu target compilation [Question]
Issue -
State: open - Opened by dgr113 over 4 years ago
- 1 comment
Labels: help wanted
#197 - Is there a way to reset the offset of a consumer group?
Issue -
State: closed - Opened by rodoufu over 4 years ago
- 7 comments
#196 - Fix tests
Pull Request -
State: closed - Opened by dead10ck over 4 years ago
- 2 comments
#195 - Fix Integration Tests due to SSL certificate
Issue -
State: closed - Opened by johnward over 4 years ago
- 4 comments
#194 - Fix test_consumer_poll tests
Issue -
State: closed - Opened by johnward over 4 years ago
- 1 comment
#193 - Fix test_commit_offsets test
Issue -
State: closed - Opened by johnward over 4 years ago
- 1 comment
#192 - Fix test_commit_offset test
Issue -
State: closed - Opened by johnward over 4 years ago
- 7 comments
Labels: First Bug
#191 - Fix test_produce_fetch_messages test
Issue -
State: closed - Opened by johnward over 4 years ago
- 1 comment
Labels: First Bug
#190 - Fix test_kafka_client_load_metadata test
Issue -
State: closed - Opened by johnward over 4 years ago
- 1 comment
Labels: First Bug
#189 - Can I limit the amount of messages I receive from kafka cluster?
Issue -
State: closed - Opened by qiujiangkun over 4 years ago
- 4 comments
#188 - Reads no messages in fetch message but raw data is present
Issue -
State: closed - Opened by qiujiangkun over 4 years ago
- 1 comment
#187 - Move Repo to new home (github.com/kafka-rust)
Issue -
State: closed - Opened by johnward over 4 years ago
- 7 comments
#186 - Support zstd compression
Issue -
State: open - Opened by fegies over 4 years ago
- 6 comments
Labels: feature
#185 - Project needs maintainer
Issue -
State: closed - Opened by dead10ck about 5 years ago
- 13 comments
#184 - Graceful shutdown of polling consumer
Issue -
State: closed - Opened by mrRo8o7 over 5 years ago
- 1 comment
#183 - Rust TLS
Pull Request -
State: closed - Opened by calavera over 5 years ago
#182 - Remove all usage of `try!`
Pull Request -
State: closed - Opened by calavera over 5 years ago
- 3 comments
#181 - Write to stream not writing full buffer
Issue -
State: open - Opened by scirner22 over 5 years ago
- 3 comments
Labels: help wanted
#180 - Mutable producer underlying client
Pull Request -
State: closed - Opened by scirner22 over 5 years ago
#179 - Code generator for kafka message format
Issue -
State: open - Opened by Diggsey over 5 years ago
- 4 comments
Labels: help wanted
#178 - Kafka Producer Many CLOSE-WAIT
Issue -
State: open - Opened by EBWi11 almost 6 years ago
- 3 comments
Labels: First Bug
#177 - Failed consuming messages: failed to lookup address information: nodename nor servname provided, or not known
Issue -
State: closed - Opened by stephenlb about 6 years ago
- 3 comments
#176 - Correct the usage of kafka-topics.sh
Pull Request -
State: closed - Opened by msk about 6 years ago
#175 - Update README.md
Pull Request -
State: closed - Opened by humb1t about 6 years ago
#174 - Update Cargo.toml
Pull Request -
State: closed - Opened by humb1t about 6 years ago
- 1 comment
#173 - Rust 2018
Pull Request -
State: closed - Opened by estk about 6 years ago
- 4 comments
#172 - error: failed to run custom build command for `openssl-sys v0.9.48`
Issue -
State: closed - Opened by KabDeveloper over 6 years ago
- 3 comments
#171 - Increase version of crate openssl from 0.9 to 0.10
Issue -
State: closed - Opened by joshushua over 6 years ago
#170 - Add support of Kafka producer transactional api
Issue -
State: open - Opened by dnrusakov over 6 years ago
- 1 comment
#169 - Consumer reconnection
Issue -
State: open - Opened by l4l over 6 years ago
- 5 comments
Labels: help wanted, First Bug
#168 - Update openssl to 0.10
Pull Request -
State: closed - Opened by l4l over 6 years ago
- 3 comments
#167 - UnknownTopicOrPartition on not yet created topic
Issue -
State: closed - Opened by mancioshell over 6 years ago
- 1 comment
#166 - Exposing compression enum as public
Pull Request -
State: closed - Opened by ttonelli almost 7 years ago
- 2 comments
#165 - grammar and such
Pull Request -
State: closed - Opened by quartzinquartz over 7 years ago
- 2 comments
#164 - Make the Error Sync
Issue -
State: open - Opened by vorner over 7 years ago
- 2 comments
#163 - How to handle MessageSizeTooLarge
Issue -
State: open - Opened by cmusser almost 8 years ago
- 7 comments
Labels: First Bug
#162 - Perform all tests under various compression and security settings
Pull Request -
State: closed - Opened by dead10ck almost 8 years ago
#161 - Fix off by one error in Consumer commits
Pull Request -
State: closed - Opened by dead10ck about 8 years ago
- 1 comment
#160 - Add client_mut function to Consumer
Pull Request -
State: closed - Opened by sevagh over 8 years ago
- 4 comments
#159 - more than one consumer in the same group receive the message?
Issue -
State: closed - Opened by kamyuentse over 8 years ago
- 8 comments
#158 - More tests
Pull Request -
State: closed - Opened by dead10ck over 8 years ago
#157 - #! Drop automatic doc upload; Rely on docs.rs
Pull Request -
State: closed - Opened by xitep over 8 years ago
#156 - switch to use error-chain
Pull Request -
State: closed - Opened by flier over 8 years ago
- 3 comments
#155 - Switch to error_chain
Issue -
State: closed - Opened by dead10ck over 8 years ago
- 1 comment
Labels: enhancement, help wanted