Skip to content

Config parameter 'coordinator_not_ready_retry_timeout_ms' #166

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

Open
wants to merge 106 commits into
base: master
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
106 commits
Select commit Hold shift + click to select a range
0b9d9e8
Config parameter 'node_not_ready_retry_timeout_ms'
zembunia Sep 11, 2017
4136b53
Merge branch 'master' into kafka_fix
zembunia Feb 9, 2018
b84088b
Merging from master
zembunia Feb 12, 2018
2f15c03
Merge branch 'master' of https://github.com/dpkp/kafka-python into ka…
zembunia Feb 12, 2018
a391cc9
coordinator_not_ready_retry_timeout_ms instead of node_not_ready_retr…
zembunia Feb 12, 2018
357474c
Merging from master
zembunia Feb 12, 2018
5eeb167
Merge branch 'master' of https://github.com/dpkp/kafka-python into ka…
zembunia Mar 29, 2018
a6d0579
Update README.rst
wbarnha Mar 8, 2024
0ab54b9
Revert "Update README.rst"
dpkp Jan 31, 2025
661f814
Fix GHA test workflow (#2456)
dpkp Feb 4, 2025
bfbee93
Refactor Makefile (#2457)
dpkp Feb 6, 2025
cfd57f2
Avoid logging errors during test fixture cleanup (#2458)
dpkp Feb 6, 2025
b8912f7
Release coordinator lock before calling maybe_leave_group (#2460)
dpkp Feb 6, 2025
aaf1bc5
Dont raise RuntimeError for dead process in SpawnedService.wait_for()…
dpkp Feb 7, 2025
47c1be6
Casts the size of a MemoryRecordsBuilder object (#2438)
hiwakaba Feb 7, 2025
a11bb7a
Update license_file to license_files (#2462)
dpkp Feb 9, 2025
5daed04
Fix DescribeConfigsResponse_v1 config_source (#150) (#2464)
dpkp Feb 10, 2025
3b0216c
Update some RST documentation syntax (#2463)
dpkp Feb 10, 2025
411e62f
Fix base class of DescribeClientQuotasResponse_v0 (#2465)
dpkp Feb 10, 2025
de43eee
Change loglevel of cancelled errors to info (#2467)
dpkp Feb 10, 2025
60ee04a
Update socketpair w/ CVE-2024-3219 fix (#2468)
dpkp Feb 12, 2025
77b2a7b
Use -Djava.security.manager=allow for Java 23 sasl tests (#2469)
dpkp Feb 12, 2025
872c1d3
Test with jvm 23 (#2470)
dpkp Feb 12, 2025
3f0e574
Update kafka properties template; disable group rebalance delay (#2471)
dpkp Feb 12, 2025
28cd0f9
Strip trailing dot off hostname. (#2472)
dpkp Feb 12, 2025
3404f25
Log connection errors at ERROR level (#2473)
dpkp Feb 12, 2025
c15720b
Add .readthedocs.yaml; update copyright date (#2474)
dpkp Feb 12, 2025
0cce043
Support DescribeLogDirs admin api (#2475)
dpkp Feb 12, 2025
8ebb14c
Fix apidoc publishing to readthedocs
dpkp Feb 12, 2025
840c0d6
Release 2.0.3
dpkp Feb 12, 2025
02dd359
Bump version for development
dpkp Feb 12, 2025
5fa8ef8
Remove old travis files; update compatibility tests link to gha
dpkp Feb 12, 2025
372aaaa
Migrate to pyproject.toml / PEP-621
dpkp Feb 13, 2025
21031e6
Handle socket init errors, e.g., when IPv6 is disabled (#2476)
dpkp Feb 13, 2025
5e4def7
Check for socket and unresolved futures before creating selector in c…
dpkp Feb 13, 2025
85eb8ad
Drop make test-local; add PYTESTS configuration var
dpkp Feb 14, 2025
252e0bd
Improve client networking backoff / retry (#2480)
dpkp Feb 14, 2025
3a0d5d6
Retain unrecognized broker response error codes with dynamic error cl…
dpkp Feb 15, 2025
226810c
Check for wakeup socket errors on read and close and reinit to reset …
dpkp Feb 16, 2025
3aa0266
Do not validate snappy xerial header version and compat fields (#2483)
dpkp Feb 17, 2025
6b3a905
Improve wakeup close
dpkp Feb 17, 2025
b7217b7
Add default resources for new kafka server fixtures (#2484)
dpkp Feb 18, 2025
776556a
Update kafka.errors w/ latest (#2485)
dpkp Feb 18, 2025
1775f43
Always log broker errors in producer.send (#2478)
dpkp Feb 20, 2025
4281e3e
Update kafka broker test matrix; test against 3.9.0 (#2486)
dpkp Feb 21, 2025
47156c3
Avoid self-join in heartbeat thread close (#2488)
dpkp Feb 21, 2025
bead350
Fixup pytest run w/o KAFKA_VERSION
dpkp Feb 21, 2025
b5985b4
Added missing docstrings in admin/client.py (#2487)
lukalafaye Feb 21, 2025
4b35502
Update kafka/admin/client docstrings to google format
dpkp Feb 21, 2025
7e59513
Release 2.0.4 (#2489)
dpkp Feb 21, 2025
a3ba6f5
Bump version for development
dpkp Feb 21, 2025
2e66623
Update compatibility docs
dpkp Feb 21, 2025
1ac8644
make servers/*/api_versions.txt and make servers/*/messages
dpkp Feb 24, 2025
e5025c8
200ms timeout for client.poll in ensure_active_group and admin client
dpkp Feb 23, 2025
1a1cc04
only acquire coordinator lock in heartbeat thread close if not self t…
dpkp Feb 24, 2025
66ad130
Check for -1 controller_id in admin client
dpkp Feb 24, 2025
6f16c46
Fixup variable interpolation in test fixture error
dpkp Feb 24, 2025
066a321
Retry on error in fixture _create_topic_via_metadata
dpkp Feb 24, 2025
905ee4c
Add error str to assert_message_count checks
dpkp Feb 24, 2025
8fdd5fc
Add timeout to test_kafka_consumer
dpkp Feb 24, 2025
d525925
Refactor sasl_integration test_client - wait for node ready; use send…
dpkp Feb 24, 2025
d7e3a60
Also sleep when waiting for consumers in test_describe_consumer_group…
dpkp Feb 24, 2025
6467a53
include client_id in BrokerConnection __str__ output
dpkp Feb 24, 2025
6ed1daa
admin client: check_version only if needed, node_id kwarg for controller
dpkp Feb 24, 2025
7b8c625
Remove unused client bootstrap backoff code
dpkp Feb 24, 2025
602f03d
fixup compatibility badges
dpkp Feb 25, 2025
334ab8f
rename make target api_versions.txt -> api_versions
dpkp Feb 25, 2025
e7437e1
Release 2.0.5
dpkp Feb 25, 2025
a014343
Bump version for development
dpkp Feb 25, 2025
a86661f
test_conn fixup for py2
dpkp Feb 25, 2025
7a15611
Add kafka command to test.brokers; raise FileNotFoundError if version…
dpkp Feb 25, 2025
fe98d6c
Only set KAFKA_JVM_PERFORMANCE_OPTS in makefile if unset; add note re…
dpkp Feb 25, 2025
b697808
Fake api_versions for old brokers, rename to ApiVersionsRequest, and …
dpkp Feb 25, 2025
5a3d95d
Add KafkaClient.api_version(operation) for best available from api_ve…
dpkp Feb 26, 2025
85a113a
Default client.check_version timeout to api_version_auto_timeout_ms (…
dpkp Feb 26, 2025
a731b18
Add support for Metadata Request/Response v7 (#2497)
dpkp Feb 26, 2025
59675e0
Decode and skip transactional control records in consumer (#2499)
dpkp Feb 26, 2025
0c65454
try / except in consumer coordinator __del__
dpkp Feb 26, 2025
837a600
Support custom per-request timeouts (#2498)
dpkp Feb 26, 2025
1594e38
Support Fetch Request/Response v6 in consumer (#2500)
dpkp Feb 27, 2025
1886cac
Support ListOffsets v3 in consumer (#2501)
dpkp Feb 27, 2025
62895a8
Support FindCoordinatorRequest v2 in consumer and admin client (#2502)
dpkp Feb 27, 2025
89c97e1
Support 2.1 baseline consumer group apis (#2503)
dpkp Feb 27, 2025
3cf418a
Improve error handling in client._maybe_connect (#2504)
dpkp Feb 27, 2025
2de3c34
Support OffsetFetch v5 / OffsetCommit v6 (2.1 baseline) (#2505)
dpkp Feb 27, 2025
e94bd4f
Add throttle warnings and top-level error handling for new offset com…
dpkp Feb 27, 2025
a3f34ef
Client connection / maybe_refresh_metadata changes (#2507)
dpkp Mar 2, 2025
3c6def9
Implement Incremental Fetch Sessions / KIP-227 (#2508)
dpkp Mar 3, 2025
3aa55a6
Improve too-large timeout handling in client poll
dpkp Mar 4, 2025
6137aed
2.0.6 changelog
dpkp Mar 4, 2025
feb3cae
Fixup fetch request forgotten_topics_data encoding
dpkp Mar 4, 2025
d036034
Fix subprocess log warning; specify timeout_ms kwarg in consumer.poll…
dpkp Mar 4, 2025
ad8d1c4
Implement client-side connection throttling / KIP-219 (#2510)
dpkp Mar 4, 2025
f465adb
Add baseline leader_epoch support for ListOffsets v4 / FetchRequest v…
dpkp Mar 5, 2025
5141d01
1.1 broker_api_versions
dpkp Mar 6, 2025
760f741
Call ApiVersionsRequest during connection, prior to Sasl Handshake (#…
dpkp Mar 8, 2025
f046b0c
Use thread-specific client_id in test_group
dpkp Mar 11, 2025
8320cc8
Refactor Sasl authentication with SaslMechanism abstract base class; …
dpkp Mar 11, 2025
6e1b9e5
Cleanup sasl mechanism configuration checks; fix gssapi bugs; add sas…
dpkp Mar 11, 2025
7e9b86b
Document api_version_auto_timeout_ms default; override in group tests
dpkp Mar 11, 2025
ef73192
Remove tox.ini; update testing docs
dpkp Mar 11, 2025
0ae708a
Make the "mock" dependency optional (only used in Python < 3.3). (#2518)
Romain-Geissler-1A Mar 11, 2025
02dd98f
Support AWS_MSK_IAM authentication (#2519)
dpkp Mar 12, 2025
57f1782
Fix lint issues via ruff check (#2522)
dpkp Mar 12, 2025
7f1bbb9
feat: Add SSPI (Kerberos for Windows) authentication mechanism (#2521)
dpkp Mar 12, 2025
3c6531c
Merge branch 'master' into kafka_fix
dpkp Mar 12, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
206 changes: 44 additions & 162 deletions .github/workflows/python-package.yml
Original file line number Diff line number Diff line change
@@ -1,198 +1,80 @@
name: CI/CD
# Derived from https://github.com/actions/starter-workflows/blob/main/ci/python-package.yml
#
name: Python Package

on:
push:
branches: ["master"]
pull_request:
branches: ["master"]
release:
types: [created]
branches:
- 'master'
workflow_dispatch:

env:
FORCE_COLOR: "1" # Make tools pretty.
PIP_DISABLE_PIP_VERSION_CHECK: "1"
PIP_NO_PYTHON_VERSION_WARNING: "1"
PYTHON_LATEST: "3.12"
KAFKA_LATEST: "2.6.0"

# For re-actors/checkout-python-sdist
sdist-artifact: python-package-distributions

jobs:
build:

build-sdist:
name: 📦 Build the source distribution
runs-on: ubuntu-latest
steps:
- name: Checkout project
uses: actions/checkout@v4
with:
fetch-depth: 0
- name: Set up Python
uses: actions/setup-python@v5
with:
python-version: ${{ env.PYTHON_LATEST }}
cache: pip
- run: python -m pip install build
name: Install core libraries for build and install
- name: Build artifacts
run: python -m build
- name: Upload built artifacts for testing
uses: actions/upload-artifact@v3
with:
name: ${{ env.sdist-artifact }}
# NOTE: Exact expected file names are specified here
# NOTE: as a safety measure — if anything weird ends
# NOTE: up being in this dir or not all dists will be
# NOTE: produced, this will fail the workflow.
path: dist/${{ env.sdist-name }}
retention-days: 15

test-python:
name: Tests on ${{ matrix.python-version }}
needs:
- build-sdist
runs-on: ubuntu-latest
continue-on-error: ${{ matrix.experimental }}
strategy:
fail-fast: false
matrix:
python-version:
- "3.8"
- "3.9"
- "3.10"
- "3.11"
- "3.12"
experimental: [ false ]
include:
- python-version: "pypy3.9"
experimental: true
- python-version: "~3.13.0-0"
experimental: true
steps:
- name: Checkout the source code
uses: actions/checkout@v4
with:
fetch-depth: 0
- name: Setup java
uses: actions/setup-java@v4
with:
distribution: temurin
java-version: 11
- name: Set up Python
uses: actions/setup-python@v5
with:
python-version: ${{ matrix.python-version }}
cache: pip
cache-dependency-path: |
requirements-dev.txt
- name: Check Java installation
run: source travis_java_install.sh
- name: Pull Kafka releases
run: ./build_integration.sh
env:
PLATFORM: ${{ matrix.platform }}
KAFKA_VERSION: ${{ env.KAFKA_LATEST }}
# TODO: Cache releases to expedite testing
- name: Install dependencies
run: |
sudo apt install -y libsnappy-dev libzstd-dev
python -m pip install --upgrade pip
python -m pip install tox tox-gh-actions
pip install .
pip install -r requirements-dev.txt
- name: Test with tox
run: tox
env:
PLATFORM: ${{ matrix.platform }}
KAFKA_VERSION: ${{ env.KAFKA_LATEST }}

test-kafka:
name: Tests for Kafka ${{ matrix.kafka-version }}
needs:
- build-sdist
runs-on: ubuntu-latest
name: "Test: python ${{ matrix.python }} / kafka ${{ matrix.kafka }}"
continue-on-error: ${{ matrix.experimental || false }}
strategy:
fail-fast: false
matrix:
kafka-version:
kafka:
- "0.8.2.2"
- "0.9.0.1"
- "0.10.2.2"
- "0.11.0.2"
- "0.11.0.3"
- "1.1.1"
- "2.4.0"
- "2.5.0"
- "2.6.0"
- "2.8.2"
- "3.0.2"
- "3.5.2"
- "3.9.0"
python:
- "3.12"
include:
#- python: "pypy3.9"
# kafka: "2.6.0"
# experimental: true
#- python: "~3.13.0-0"
# kafka: "2.6.0"
# experimental: true
- python: "3.8"
kafka: "3.9.0"
- python: "3.9"
kafka: "3.9.0"
- python: "3.10"
kafka: "3.9.0"
- python: "3.11"
kafka: "3.9.0"

steps:
- name: Checkout the source code
uses: actions/checkout@v4
with:
fetch-depth: 0
- name: Setup java
uses: actions/setup-java@v4
with:
distribution: temurin
java-version: 8
- name: Set up Python
- uses: actions/checkout@v4
- name: Set up Python ${{ matrix.python }}
uses: actions/setup-python@v5
with:
python-version: ${{ env.PYTHON_LATEST }}
python-version: ${{ matrix.python }}
cache: pip
cache-dependency-path: |
requirements-dev.txt
- name: Pull Kafka releases
run: ./build_integration.sh
env:
# This is fast enough as long as you pull only one release at a time,
# no need to worry about caching
PLATFORM: ${{ matrix.platform }}
KAFKA_VERSION: ${{ matrix.kafka-version }}
- name: Install dependencies
run: |
sudo apt install -y libsnappy-dev libzstd-dev
python -m pip install --upgrade pip
python -m pip install tox tox-gh-actions
pip install .
pip install -r requirements-dev.txt
- name: Test with tox
run: tox
env:
PLATFORM: ${{ matrix.platform }}
KAFKA_VERSION: ${{ matrix.kafka-version }}

check: # This job does nothing and is only used for the branch protection
name: ✅ Ensure the required checks passing
if: always()
needs:
- build-sdist
- test-python
- test-kafka
runs-on: ubuntu-latest
steps:
- name: Decide whether the needed jobs succeeded or failed
uses: re-actors/alls-green@release/v1
with:
jobs: ${{ toJSON(needs) }}
publish:
name: 📦 Publish to PyPI
runs-on: ubuntu-latest
needs: [build-sdist]
permissions:
id-token: write
environment: pypi
if: github.event_name == 'release' && github.event.action == 'created'
steps:
- name: Download the sdist artifact
uses: actions/download-artifact@v3
with:
name: artifact
path: dist
- name: Publish package to PyPI
uses: pypa/gh-action-pypi-publish@release/v1
- name: Pylint
run: pylint --recursive=y --errors-only --exit-zero kafka test
- name: Setup java
uses: actions/setup-java@v4
with:
password: ${{ secrets.PYPI_API_TOKEN }}
distribution: temurin
java-version: 23
- name: Pull Kafka release
run: make servers/${{ matrix.kafka }}/kafka-bin
- name: Pytest
run: make test
env:
KAFKA_VERSION: ${{ matrix.kafka }}
35 changes: 35 additions & 0 deletions .readthedocs.yaml
Original file line number Diff line number Diff line change
@@ -0,0 +1,35 @@
# Read the Docs configuration file for Sphinx projects
# See https://docs.readthedocs.io/en/stable/config-file/v2.html for details

# Required
version: 2

# Set the OS, Python version and other tools you might need
build:
os: ubuntu-22.04
tools:
python: "3.12"
# You can also specify other tool versions:
# nodejs: "20"
# rust: "1.70"
# golang: "1.20"

# Build documentation in the "docs/" directory with Sphinx
sphinx:
configuration: docs/conf.py
# You can configure Sphinx to use a different builder, for instance use the dirhtml builder for simpler URLs
# builder: "dirhtml"
# Fail on all warnings to avoid broken references
# fail_on_warning: true

# Optionally build your docs in additional formats such as PDF and ePub
# formats:
# - pdf
# - epub

# Optional but recommended, declare the Python requirements required
# to build your documentation
# See https://docs.readthedocs.io/en/stable/guides/reproducible-builds.html
python:
install:
- requirements: docs/requirements.txt
46 changes: 0 additions & 46 deletions .travis.yml

This file was deleted.

Loading