rust-rdkafka

rust-rdkafka copied to clipboard

Some methods are not provided as async

6

For example, `offsets_for_times`, even with a timeout, does not have na async equivalent, and I have to use `block_in_place` to work around it

JakkuSakura

WIP: Mock cluster support

6

This is an attempt to expose the mock cluster somewhat directly. This allows for control over the mock cluster, giving end users the ability to alter behaviors for a degree...

GregBowyer

Upgrade librdkafka to v1.9.0.

13

Resolves #485

gyfis

Rework OAuth callback to avoid memory unsafety and follow conventions

3

@duarten @jsurany-bloomberg these changes are a result of me eyeballing the diff in #442. Any chance one of you is able to test? I don't have easy access to a...

benesch

Improve documentation for Commit Offset semantics

1

Hello, Let me start with a quick thank you to all who maintain this Rust crate! I had been struggling with an off-by-one error which caused my consumer service to...

aarashy

Bumps [openssl-src](https://github.com/alexcrichton/openssl-src-rs) from 111.17.0+1.1.1m to 111.22.0+1.1.1q. Commits See full diff in compare view [](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter...

dependabot[bot]

Failing to compile 0.28.0 for Windows and musl platforms with vendored openssl

7

Hey! Apologies, I tried to nail this down myself, but have been banging my head against it all day and thought maybe you would have some insight. We have a...

jszwedko

librdkafka v1.9.0 is released [ https://github.com/edenhill/librdkafka/releases/tag/v1.9.0]( https://github.com/edenhill/librdkafka/releases/tag/v1.9.0), is there any plan to upgrade rust-rdkafka?

ikey4u

Error: Unknow Group When Mannually Assign Topic

1

According the kafka documentation if I use assign instead of subscribe method, I don't need to set a group id, but I got the following error: Can't subscribe to specified...

jesseXu

Bumps [thread_local](https://github.com/Amanieu/thread_local-rs) from 1.0.1 to 1.1.4. Commits 4a54e57 Bump version to 1.1.4 ebf8b45 Merge pull request #34 from ibraheemdev/patch-1 3d69afa Fix memory ordering in RawIter::next c7d8dcd Bump version to 1.1.3...

dependabot[bot]