Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

0.37.0 is having issues with topic deletion #754

Open
DoumanAsh opened this issue Dec 30, 2024 · 3 comments
Open

0.37.0 is having issues with topic deletion #754

DoumanAsh opened this issue Dec 30, 2024 · 3 comments

Comments

@DoumanAsh
Copy link

DoumanAsh commented Dec 30, 2024

Using current latest version 0.37.0 of bindings I see issue with deliting existing topic
It seems rdkafka is waiting for something to happen while topic is being deleted:

cargo/registry/src/index.crates.io-6f17d22bba15001f/rdkafka-0.37.0/src/client.rs:80} - librdkafka: PARTCNT [thrd:main]: Topic status_test partition count changed from 1 to 0

Even though I can see kafka itself reporting that topic has been deleted successfully
It is currently not clear what changed since 2.3.0's librdkafka, but at least curent librdkafka used in bindings has admin client broken

@DoumanAsh
Copy link
Author

Using librdkafka 2.6.1 resolves this issue

@DoumanAsh
Copy link
Author

Actually nevermind that
I tried to use master branch of this repo, and it works without issues...
So there might be something wrong with currently published version of rdkafka crate?

@DoumanAsh DoumanAsh changed the title librdkafka 2.3.0 is having issues with topic deletion 0.37.0 is having issues with topic deletion Dec 30, 2024
@DoumanAsh
Copy link
Author

Did re-test today properly

Current version 0.37.0 using librdkafka 2.3.0 is having issue with exiting topic deletion function
Updating librdkafka to 2.4.0 fixes it

librdkafka v2.8.0 also doesn't have issue

Looking at changelog I do not see any particular reason but it is what it is

Method in question:
https://docs.rs/rdkafka/0.37.0/rdkafka/admin/struct.AdminClient.html#method.delete_topics

C function under impact:
rd_kafka_DeleteTopics

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant