Skip to content

KIP-70: Auto-commit offsets on consumer.unsubscribe(), defer assignment changes to rejoin #2560

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

Merged
merged 6 commits into from
Mar 24, 2025

Conversation

dpkp
Copy link
Owner

@dpkp dpkp commented Mar 22, 2025

Fix #1242

@dpkp dpkp merged commit 3f3c424 into master Mar 24, 2025
18 checks passed
@dpkp dpkp deleted the dpkp/kip-70 branch March 24, 2025 18:14
Comment on lines +5 to +7
from collections import Sequence
except ImportError:
from collections.abc import Sequence
Copy link

@millerdev millerdev Mar 26, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This causes DeprecationWarning: Using or importing the ABCs from 'collections' instead of from 'collections.abc' is deprecated since Python 3.3, and in 3.10 it will stop working

I think the imports should be reversed here:

Suggested change
from collections import Sequence
except ImportError:
from collections.abc import Sequence
from collections.abc import Sequence
except ImportError:
from collections import Sequence

Or possibly just replace the entire try/except with a single import since the other import is only valid on very old/outdated Pythons.

from collections.abc import Sequence

Copy link
Owner Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

thanks, yea we still support very old pythons (2.7). I did try old, except new but that does cause deprecation warnings for interim pythons. I can see how you might prefer try new, except old

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

Successfully merging this pull request may close these issues.

KIP-70 / KAFKA-4033: Cleanup inconsistencies in partition assignment semantics
2 participants