Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / kafka-rust/kafka-rust issues and pull requests

#236 - Add CI, Make tests work, Deprecate EOL releases, Update Deps

Pull Request - State: open - Opened by oneslash 12 days ago - 1 comment

#235 - CI update and drop old versions

Issue - State: open - Opened by oneslash 13 days ago

#234 - Message timestamp

Issue - State: open - Opened by kalimalrazif about 2 months ago

#233 - refactor: fix clippy lints

Pull Request - State: open - Opened by ByteBaker 3 months ago

#232 - How to connect using credentials, like username and password?

Issue - State: open - Opened by AliElMoussawi 5 months ago - 4 comments

#231 - Two consumers both can receive the same message with same group and topic

Issue - State: open - Opened by Xu-Mj 6 months ago - 1 comment

#230 - how to create and delete topic with kafka-rust

Issue - State: open - Opened by Jungle666 7 months ago

#229 - See message headers

Issue - State: open - Opened by conradogarciaberrotaran 7 months ago

#228 - UnknowTopicOrPartitiion Error

Issue - State: open - Opened by vizvasrj 8 months ago

#226 - Consume from Latest

Issue - State: open - Opened by evanzhang87 9 months ago

#225 - commit_consumed RequestTimedOut

Issue - State: open - Opened by evanzhang87 10 months ago

#223 - list offsets

Pull Request - State: open - Opened by YilunAllenChen 11 months ago

#222 - seek

Pull Request - State: open - Opened by YilunAllenChen 11 months ago

#221 - list offsets

Pull Request - State: closed - Opened by YilunAllenChen 11 months ago - 1 comment

#220 - docs: fix comments in `src/consumer/mod.rs`

Pull Request - State: closed - Opened by hamirmahal over 1 year ago

#219 - is this repo being maintained?

Issue - State: closed - Opened by ravieze over 1 year ago - 6 comments

#218 - How to get the offset of the last message in a partition?

Issue - State: open - Opened by ravieze over 1 year ago

#217 - TLS max record size

Issue - State: open - Opened by bellefab over 1 year ago

#216 - docs: Fix grammar mistakes in README.md

Pull Request - State: closed - Opened by joshua-mo-143 over 1 year ago - 1 comment

#215 - Add missing spaces in the README

Pull Request - State: closed - Opened by aaabramov almost 2 years ago

#214 - Version 0.9

Issue - State: open - Opened by Raawaan almost 2 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 2 years ago - 1 comment

#212 - Sending message with headers

Issue - State: open - Opened by mesuutt about 2 years ago - 2 comments

#210 - How to get message timestamp

Issue - State: open - Opened by Mrzrb over 2 years ago - 2 comments

#209 - Formatting, dependency upgrade, and some niceties

Pull Request - State: closed - Opened by midnightexigent over 2 years ago - 1 comment

#208 - Protocol Rework

Pull Request - State: open - Opened by midnightexigent over 2 years ago

#207 - Addition of upstash sponsorship

Pull Request - State: closed - Opened by johnward over 2 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 2 years ago - 2 comments

#205 - [Feature] Versions handling

Issue - State: open - Opened by Dzordzu over 2 years ago - 8 comments

#204 - [Feature request] Support for rebalancing and heartbeat

Issue - State: open - Opened by Dzordzu over 2 years ago - 8 comments

#203 - Depency upgrade & Minor refactorings

Pull Request - State: closed - Opened by midnightexigent over 2 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 almost 3 years ago - 3 comments

#201 - bump deps

Pull Request - State: closed - Opened by tshepang about 3 years ago

#200 - use automatic tooling to modernise codebase

Pull Request - State: closed - Opened by tshepang about 3 years ago - 4 comments

#199 - "for ms in consumer.poll().unwrap().iter()" produces temporary value error

Issue - State: closed - Opened by sempervictus about 3 years ago - 3 comments

#198 - windows-gnu target compilation [Question]

Issue - State: open - Opened by dgr113 over 3 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 3 years ago - 7 comments

#196 - Fix tests

Pull Request - State: closed - Opened by dead10ck over 3 years ago - 2 comments

#195 - Fix Integration Tests due to SSL certificate

Issue - State: closed - Opened by johnward over 3 years ago - 4 comments

#194 - Fix test_consumer_poll tests

Issue - State: closed - Opened by johnward over 3 years ago - 1 comment

#193 - Fix test_commit_offsets test

Issue - State: closed - Opened by johnward over 3 years ago - 1 comment

#192 - Fix test_commit_offset test

Issue - State: closed - Opened by johnward over 3 years ago - 7 comments
Labels: First Bug

#191 - Fix test_produce_fetch_messages test

Issue - State: closed - Opened by johnward over 3 years ago - 1 comment
Labels: First Bug

#190 - Fix test_kafka_client_load_metadata test

Issue - State: closed - Opened by johnward over 3 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 3 years ago - 4 comments

#188 - Reads no messages in fetch message but raw data is present

Issue - State: closed - Opened by qiujiangkun over 3 years ago - 1 comment

#187 - Move Repo to new home (github.com/kafka-rust)

Issue - State: closed - Opened by johnward over 3 years ago - 7 comments

#186 - Support zstd compression

Issue - State: open - Opened by fegies over 3 years ago - 6 comments
Labels: feature

#185 - Project needs maintainer

Issue - State: closed - Opened by dead10ck about 4 years ago - 13 comments

#184 - Graceful shutdown of polling consumer

Issue - State: closed - Opened by mrRo8o7 over 4 years ago - 1 comment

#183 - Rust TLS

Pull Request - State: closed - Opened by calavera over 4 years ago

#182 - Remove all usage of `try!`

Pull Request - State: closed - Opened by calavera over 4 years ago - 3 comments

#181 - Write to stream not writing full buffer

Issue - State: open - Opened by scirner22 over 4 years ago - 3 comments
Labels: help wanted

#180 - Mutable producer underlying client

Pull Request - State: closed - Opened by scirner22 over 4 years ago

#179 - Code generator for kafka message format

Issue - State: open - Opened by Diggsey over 4 years ago - 4 comments
Labels: help wanted

#178 - Kafka Producer Many CLOSE-WAIT

Issue - State: open - Opened by EBWi11 over 4 years ago - 3 comments
Labels: First Bug

#176 - Correct the usage of kafka-topics.sh

Pull Request - State: closed - Opened by msk almost 5 years ago

#175 - Update README.md

Pull Request - State: closed - Opened by humb1t about 5 years ago

#174 - Update Cargo.toml

Pull Request - State: closed - Opened by humb1t about 5 years ago - 1 comment

#173 - Rust 2018

Pull Request - State: closed - Opened by estk about 5 years ago - 4 comments

#172 - error: failed to run custom build command for `openssl-sys v0.9.48`

Issue - State: closed - Opened by KabDeveloper about 5 years ago - 3 comments

#171 - Increase version of crate openssl from 0.9 to 0.10

Issue - State: closed - Opened by joshushua about 5 years ago

#170 - Add support of Kafka producer transactional api

Issue - State: open - Opened by dnrusakov over 5 years ago - 1 comment

#169 - Consumer reconnection

Issue - State: open - Opened by l4l over 5 years ago - 5 comments
Labels: help wanted, First Bug

#168 - Update openssl to 0.10

Pull Request - State: closed - Opened by l4l over 5 years ago - 3 comments

#167 - UnknownTopicOrPartition on not yet created topic

Issue - State: closed - Opened by mancioshell over 5 years ago - 1 comment

#166 - Exposing compression enum as public

Pull Request - State: closed - Opened by ttonelli almost 6 years ago - 2 comments

#165 - grammar and such

Pull Request - State: closed - Opened by quartzinquartz over 6 years ago - 2 comments

#164 - Make the Error Sync

Issue - State: open - Opened by vorner over 6 years ago - 2 comments

#163 - How to handle MessageSizeTooLarge

Issue - State: open - Opened by cmusser almost 7 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 7 years ago

#161 - Fix off by one error in Consumer commits

Pull Request - State: closed - Opened by dead10ck almost 7 years ago - 1 comment

#160 - Add client_mut function to Consumer

Pull Request - State: closed - Opened by sevagh about 7 years ago - 4 comments

#159 - more than one consumer in the same group receive the message?

Issue - State: closed - Opened by kamyuentse over 7 years ago - 8 comments

#158 - More tests

Pull Request - State: closed - Opened by dead10ck over 7 years ago

#157 - #! Drop automatic doc upload; Rely on docs.rs

Pull Request - State: closed - Opened by xitep over 7 years ago

#156 - switch to use error-chain

Pull Request - State: closed - Opened by flier over 7 years ago - 3 comments

#155 - Switch to error_chain

Issue - State: closed - Opened by dead10ck over 7 years ago - 1 comment
Labels: enhancement, help wanted

#154 - Reading compressed message sets fails with UnexpectedEOF

Issue - State: closed - Opened by xitep over 7 years ago - 1 comment

#153 - topic-metadata: output partitions' replication state

Issue - State: open - Opened by xitep over 7 years ago
Labels: help wanted, feature

#152 - support LZ4 compression

Pull Request - State: open - Opened by flier over 7 years ago - 10 comments

#151 - #145 Replace SipHasher with XxHash

Pull Request - State: closed - Opened by xitep over 7 years ago - 10 comments

#150 - use `native-tls` instead of `openssl`

Pull Request - State: closed - Opened by flier over 7 years ago - 12 comments

#148 - use `snap` instead of `snappy` which base on libsnappy

Pull Request - State: closed - Opened by flier over 7 years ago - 11 comments

#147 - migrate to openssl v0.9 API

Pull Request - State: closed - Opened by flier over 7 years ago - 4 comments

#145 - SipHasher has been deprecated

Issue - State: closed - Opened by dead10ck over 7 years ago - 5 comments
Labels: 0.6.x

#144 - cargo fmt

Pull Request - State: closed - Opened by dead10ck over 7 years ago - 1 comment

#143 - Basic integration testing framework

Pull Request - State: closed - Opened by dead10ck over 7 years ago - 4 comments
Labels: enhancement, 0.6.x

#142 - Tokio integration?

Issue - State: closed - Opened by pimeys over 7 years ago - 1 comment

#141 - Fix index of out bounds error

Pull Request - State: closed - Opened by xitep almost 8 years ago - 4 comments

#140 - Allow specifying client_id

Pull Request - State: closed - Opened by xitep almost 8 years ago - 7 comments
Labels: feature, 0.6.x

#139 - Feat: create KafkaClient with a client_id

Pull Request - State: closed - Opened by Morsicus almost 8 years ago - 5 comments

#138 - Integration testing

Issue - State: open - Opened by dead10ck almost 8 years ago - 7 comments
Labels: enhancement, help wanted

#137 - Provide Consumer#subscriptions

Pull Request - State: closed - Opened by xitep almost 8 years ago - 2 comments
Labels: enhancement, 0.6.x