Build wheels for Python 3.14 (#1140)

* Build for Python 3.14

* Update dependencies; fix linting errors

* Use 3.11 for cibuildwheel

* Deprecated macos-13 -> macos-15-intel

Author: ods

.github/workflows/publish.yml

@@ -42,7 +42,7 @@ jobs:
             arch: x86_64
           - os: ubuntu-latest
             arch: aarch64
-          - os: macos-13
+          - os: macos-15-intel
             arch: x86_64
           - os: macos-latest
             arch: arm64
@@ -52,14 +52,15 @@ jobs:
       - uses: actions/checkout@v4
       - uses: actions/setup-python@v5
         with:
-          python-version: "3.10"
+          # cibuildwheel requires 3.11+
+          python-version: "3.11"
       - name: Set up QEMU
         if: ${{ matrix.arch == 'aarch64' }}
         uses: docker/setup-qemu-action@v3
       - name: Build wheels
         env:
           CIBW_ARCHS_LINUX: ${{matrix.arch}}
-          CIBW_BUILD: cp39-* cp310-* cp311-* cp312-* cp313-*
+          CIBW_BUILD: cp310-* cp311-* cp312-* cp313-* cp314-*
           CIBW_SKIP: '*-musllinux*'
           CIBW_BEFORE_BUILD_LINUX: pip install -r requirements-cython.txt && yum install -y zlib-devel
           # On windows and mac we should have z library preinstalled
@@ -82,7 +83,7 @@ jobs:
 
     strategy:
       matrix:
-        python: ["3.10", "3.11", "3.12", "3.13"]
+        python: ["3.10", "3.11", "3.12", "3.13", "3.14"]
         include:
           - python: "3.10"
             aiokafka_whl: dist/aiokafka-*-cp310-cp310-win_amd64.whl
@@ -92,6 +93,8 @@ jobs:
             aiokafka_whl: dist/aiokafka-*-cp312-cp312-win_amd64.whl
           - python: "3.13"
             aiokafka_whl: dist/aiokafka-*-cp313-cp313-win_amd64.whl
+          - python: "3.14"
+            aiokafka_whl: dist/aiokafka-*-cp314-cp314-win_amd64.whl
 
     steps:
       - uses: actions/checkout@v4
@@ -121,11 +124,11 @@ jobs:
 
   test-wheels-mac:
     needs: [package-source, package-wheel]
-    runs-on: macos-13
+    runs-on: macos-15-intel
 
     strategy:
       matrix:
-        python: ["3.10", "3.11", "3.12", "3.13"]
+        python: ["3.10", "3.11", "3.12", "3.13", "3.14"]
         include:
           - python: "3.10"
             aiokafka_whl: dist/aiokafka-*-cp310-cp310-macosx_*_x86_64.whl
@@ -135,13 +138,15 @@ jobs:
             aiokafka_whl: dist/aiokafka-*-cp312-cp312-macosx_*_x86_64.whl
           - python: "3.13"
             aiokafka_whl: dist/aiokafka-*-cp313-cp313-macosx_*_x86_64.whl
+          - python: "3.14"
+            aiokafka_whl: dist/aiokafka-*-cp314-cp314-macosx_*_x86_64.whl
 
     steps:
       - uses: actions/checkout@v4
       - name: Download distributions
         uses: actions/download-artifact@v4
         with:
-          name: dist-macos-13-x86_64
+          name: dist-macos-15-intel-x86_64
           path: dist/
       - name: Set up Python
         uses: actions/setup-python@v5
@@ -166,7 +171,7 @@ jobs:
 
     strategy:
       matrix:
-        python: ["3.10", "3.11", "3.12", "3.13"]
+        python: ["3.10", "3.11", "3.12", "3.13", "3.14"]
         include:
           - python: "3.10"
             aiokafka_whl: dist/aiokafka-*-cp310-cp310-macosx_*_arm64.whl
@@ -176,6 +181,8 @@ jobs:
             aiokafka_whl: dist/aiokafka-*-cp312-cp312-macosx_*_arm64.whl
           - python: "3.13"
             aiokafka_whl: dist/aiokafka-*-cp313-cp313-macosx_*_arm64.whl
+          - python: "3.14"
+            aiokafka_whl: dist/aiokafka-*-cp314-cp314-macosx_*_arm64.whl
 
     steps:
       - uses: actions/checkout@v4
@@ -207,7 +214,7 @@ jobs:
 
     strategy:
       matrix:
-        python: ["3.10", "3.11", "3.12", "3.13"]
+        python: ["3.10", "3.11", "3.12", "3.13", "3.14"]
         include:
           - python: "3.10"
             aiokafka_whl: dist/aiokafka-*-cp310-cp310-manylinux*_x86_64.whl
@@ -217,6 +224,8 @@ jobs:
             aiokafka_whl: dist/aiokafka-*-cp312-cp312-manylinux*_x86_64.whl
           - python: "3.13"
             aiokafka_whl: dist/aiokafka-*-cp313-cp313-manylinux*_x86_64.whl
+          - python: "3.14"
+            aiokafka_whl: dist/aiokafka-*-cp314-cp314-manylinux*_x86_64.whl
 
     steps:
       - uses: actions/checkout@v4
@@ -256,8 +265,6 @@ jobs:
     strategy:
       matrix:
         include:
-          - pyver: cp39-cp39
-            aiokafka_whl: dist/aiokafka-*-cp39-cp39-manylinux*_aarch64.whl
           - pyver: cp310-cp310
             aiokafka_whl: dist/aiokafka-*-cp310-cp310-manylinux*_aarch64.whl
           - pyver: cp311-cp311
@@ -266,6 +273,8 @@ jobs:
             aiokafka_whl: dist/aiokafka-*-cp312-cp312-manylinux*_aarch64.whl
           - pyver: cp313-cp313
             aiokafka_whl: dist/aiokafka-*-cp313-cp313-manylinux*_aarch64.whl
+          - pyver: cp314-cp314
+            aiokafka_whl: dist/aiokafka-*-cp314-cp314-manylinux*_aarch64.whl
 
     steps:
       - uses: actions/checkout@v4

.github/workflows/tests.yml

@@ -73,7 +73,7 @@ jobs:
 
     strategy:
       matrix:
-        python: ["3.10", "3.11", "3.12", "3.13"]
+        python: ["3.10", "3.11", "3.12", "3.13", "3.14"]
 
     steps:
     - uses: actions/checkout@v4
@@ -141,7 +141,7 @@ jobs:
 
     strategy:
       matrix:
-        python: ["3.10", "3.11", "3.12", "3.13"]
+        python: ["3.10", "3.11", "3.12", "3.13", "3.14"]
 
     steps:
     - uses: actions/checkout@v4
@@ -210,7 +210,7 @@ jobs:
     strategy:
       matrix:
         include:
-          - python: "3.13"
+          - python: "3.14"
             kafka: "2.8.1"
             scala: "2.13"
 
@@ -224,33 +224,36 @@ jobs:
           - python: "3.12"
             kafka: "2.8.1"
             scala: "2.13"
+          - python: "3.13"
+            kafka: "2.8.1"
+            scala: "2.13"
 
           # Older brokers against latest python version
-          - python: "3.13"
+          - python: "3.14"
             kafka: "0.11.0.3"
             scala: "2.12"
-          - python: "3.13"
+          - python: "3.14"
             kafka: "1.1.1"
             scala: "2.12"
-          - python: "3.13"
+          - python: "3.14"
             kafka: "2.1.1"
             scala: "2.12"
-          - python: "3.13"
+          - python: "3.14"
             kafka: "2.2.2"
             scala: "2.12"
-          - python: "3.13"
+          - python: "3.14"
             kafka: "2.3.1"
             scala: "2.12"
-          - python: "3.13"
+          - python: "3.14"
             kafka: "2.4.1"
             scala: "2.12"
-          - python: "3.13"
+          - python: "3.14"
             kafka: "2.5.1"
             scala: "2.12"
-          - python: "3.13"
+          - python: "3.14"
             kafka: "2.6.3"
             scala: "2.12"
-          - python: "3.13"
+          - python: "3.14"
             kafka: "2.7.2"
             scala: "2.13"
       fail-fast: false

aiokafka/__init__.py

@@ -12,7 +12,7 @@
     TopicPartition,
 )
 
-__all__ = [
+__all__ = [  # noqa: RUF022
     # Clients API
     "AIOKafkaProducer",
     "AIOKafkaConsumer",

aiokafka/client.py

@@ -179,9 +179,9 @@ async def close(self):
 
     async def bootstrap(self):
         """Try to to bootstrap initial cluster metadata"""
-        assert (
-            self._loop is get_running_loop()
-        ), "Please create objects with the same loop as running with"
+        assert self._loop is get_running_loop(), (
+            "Please create objects with the same loop as running with"
+        )
 
         for host, port, _ in self.hosts:
             log.debug("Attempting to bootstrap via node at %s:%s", host, port)

aiokafka/cluster.py

@@ -390,8 +390,7 @@ def add_coordinator(self, node_id, host, port, rack=None, *, purpose):
         self._coordinator_by_key[purpose] = node_id
 
     def __str__(self):
-        return "ClusterMetadata(brokers: %d, topics: %d, groups: %d)" % (
-            len(self._brokers),
-            len(self._partitions),
-            len(self._groups),
+        return (
+            f"ClusterMetadata(brokers: {len(self._brokers)}, topics: "
+            f"{len(self._partitions)}, groups: {len(self._groups)})"
         )

aiokafka/conn.py

@@ -138,9 +138,9 @@ def __init__(
                     "sasl_oauth_token_provider needs to be"
                     " provided implementing aiokafka.abc.AbstractTokenProvider"
                 )
-            assert callable(
-                getattr(sasl_oauth_token_provider, "token", None)
-            ), "sasl_oauth_token_provider must implement method #token()"
+            assert callable(getattr(sasl_oauth_token_provider, "token", None)), (
+                "sasl_oauth_token_provider must implement method #token()"
+            )
 
         self._loop = loop
         self._host = host

aiokafka/consumer/consumer.py

@@ -357,9 +357,9 @@ async def start(self):
         * Wait for possible topic autocreation
         * Join group if ``group_id`` provided
         """
-        assert (
-            self._loop is get_running_loop()
-        ), "Please create objects with the same loop as running with"
+        assert self._loop is get_running_loop(), (
+            "Please create objects with the same loop as running with"
+        )
         assert self._fetcher is None, "Did you call `start` twice?"
         await self._client.bootstrap()
         await self._wait_topics()

aiokafka/consumer/fetcher.py

@@ -225,9 +225,9 @@ def _unpack_records(self):
                 self._consume_aborted_up_to(next_batch.base_offset)
 
                 if (
-                    next_batch.is_control_batch  # fmt: skip
+                    next_batch.is_control_batch
                     and self._contains_abort_marker(next_batch)
-                ):
+                ):  # fmt: skip
                     # Using `discard` instead of `remove`, because Kafka
                     # may return an abort marker for an otherwise empty
                     # topic-partition.
@@ -977,9 +977,9 @@ async def _proc_offset_request(self, node_id, topic_data):
                 if error_type is Errors.NoError:
                     if response.API_VERSION == 0:
                         offsets = partition_info[0]
-                        assert (
-                            len(offsets) <= 1
-                        ), "Expected OffsetResponse with one offset"
+                        assert len(offsets) <= 1, (
+                            "Expected OffsetResponse with one offset"
+                        )
                         if offsets:
                             offset = offsets[0]
                             log.debug(

aiokafka/consumer/group_coordinator.py

@@ -435,7 +435,7 @@ async def _perform_assignment(self, response: Response):
         all_subscribed_topics = set()
         for member in members:
             if response.API_VERSION == 5:
-                member_id, group_instance_id, metadata_bytes = member
+                member_id, _group_instance_id, metadata_bytes = member
             else:
                 member_id, metadata_bytes = member
             metadata = ConsumerProtocol.METADATA.decode(metadata_bytes)
@@ -675,7 +675,7 @@ async def __coordination_routine(self):
             if self._commit_refresh_task:
                 futures.append(self._commit_refresh_task)
 
-            done, _ = await asyncio.wait(
+            await asyncio.wait(
                 futures, timeout=wait_timeout, return_when=asyncio.FIRST_COMPLETED
             )
 

aiokafka/consumer/subscription_state.py

@@ -338,9 +338,9 @@ def assignment(self):
 
     def _assign(self, topic_partitions: Iterable[TopicPartition]):
         for tp in topic_partitions:
-            assert (
-                tp.topic in self._topics
-            ), f"Received an assignment for unsubscribed topic: {tp}"
+            assert tp.topic in self._topics, (
+                f"Received an assignment for unsubscribed topic: {tp}"
+            )
 
         if self._assignment is not None:
             self._assignment._unassign()