pkgsrc-Changes archive
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index][Old Index]

CVS commit: pkgsrc/devel/py-kafka-python

Module Name:    pkgsrc
Committed By:   adam
Date:           Wed Jun 24 08:49:54 UTC 2026

Modified Files:
        pkgsrc/devel/py-kafka-python: Makefile PLIST distinfo
Added Files:
        pkgsrc/devel/py-kafka-python: ALTERNATIVES

Log Message:
py-kafka-python: updated to 3.0.4

3.0.4 (Jun 23, 2026)

Fixes
* Fix `_build_transport` / `conn.close` race
* net.transport: Fix closed/write_eof handling in `_write_to_sock`
* Fix kafka.net.connection await: raise connection failures

Logging
* bootstrap connection log changes
* Improve connection logging; dont log version check if matches expected
* tests: print integration fixture output to console if no log handlers

Documentation
* docs: Add title headings for KafkaConsumer/KafkaProducer; add sphinx-argparse to requirements-dev.txt


To generate a diff of this commit:
cvs rdiff -u -r0 -r1.1 pkgsrc/devel/py-kafka-python/ALTERNATIVES
cvs rdiff -u -r1.3 -r1.4 pkgsrc/devel/py-kafka-python/Makefile
cvs rdiff -u -r1.2 -r1.3 pkgsrc/devel/py-kafka-python/PLIST
cvs rdiff -u -r1.4 -r1.5 pkgsrc/devel/py-kafka-python/distinfo

Please note that diffs are not public domain; they are subject to the
copyright notices on the relevant files.


Modified files:

Index: pkgsrc/devel/py-kafka-python/Makefile
diff -u pkgsrc/devel/py-kafka-python/Makefile:1.3 pkgsrc/devel/py-kafka-python/Makefile:1.4
--- pkgsrc/devel/py-kafka-python/Makefile:1.3   Tue Jan  4 20:53:14 2022
+++ pkgsrc/devel/py-kafka-python/Makefile       Wed Jun 24 08:49:54 2026
@@ -1,8 +1,7 @@
-# $NetBSD: Makefile,v 1.3 2022/01/04 20:53:14 wiz Exp $
+# $NetBSD: Makefile,v 1.4 2026/06/24 08:49:54 adam Exp $
 
-DISTNAME=      kafka-python-1.4.4
-PKGNAME=       ${PYPKGPREFIX}-${DISTNAME}
-PKGREVISION=   1
+DISTNAME=      kafka_python-3.0.4
+PKGNAME=       ${PYPKGPREFIX}-${DISTNAME:S/_/-/}
 CATEGORIES=    devel python
 MASTER_SITES=  ${MASTER_SITE_PYPI:=k/kafka-python/}
 
@@ -11,10 +10,13 @@ HOMEPAGE=   https://github.com/dpkp/kafka-
 COMMENT=       Pure Python client for Apache Kafka
 LICENSE=       apache-2.0
 
-TEST_DEPENDS+= ${PYPKGPREFIX}-mock-[0-9]*:../../devel/py-mock
-TEST_DEPENDS+= ${PYPKGPREFIX}-tox-[0-9]*:../../devel/py-tox
+TOOL_DEPENDS+= ${PYPKGPREFIX}-setuptools>=78:../../devel/py-setuptools
+TEST_DEPENDS+= ${PYPKGPREFIX}-test-mock-[0-9]*:../../devel/py-test-mock
+TEST_DEPENDS+= ${PYPKGPREFIX}-test-timeout-[0-9]*:../../devel/py-test-timeout
 
 USE_LANGUAGES= # none
 
-.include "../../lang/python/egg.mk"
+PY_RENAME_BINARIES=    kafka-python
+
+.include "../../lang/python/wheel.mk"
 .include "../../mk/bsd.pkg.mk"

Index: pkgsrc/devel/py-kafka-python/PLIST
diff -u pkgsrc/devel/py-kafka-python/PLIST:1.2 pkgsrc/devel/py-kafka-python/PLIST:1.3
--- pkgsrc/devel/py-kafka-python/PLIST:1.2      Tue Dec  4 12:54:01 2018
+++ pkgsrc/devel/py-kafka-python/PLIST  Wed Jun 24 08:49:54 2026
@@ -1,68 +1,260 @@
-@comment $NetBSD: PLIST,v 1.2 2018/12/04 12:54:01 adam Exp $
-${PYSITELIB}/${EGG_INFODIR}/PKG-INFO
-${PYSITELIB}/${EGG_INFODIR}/SOURCES.txt
-${PYSITELIB}/${EGG_INFODIR}/dependency_links.txt
-${PYSITELIB}/${EGG_INFODIR}/top_level.txt
+@comment $NetBSD: PLIST,v 1.3 2026/06/24 08:49:54 adam Exp $
+bin/kafka-python-${PYVERSSUFFIX}
+${PYSITELIB}/${WHEEL_INFODIR}/METADATA
+${PYSITELIB}/${WHEEL_INFODIR}/RECORD
+${PYSITELIB}/${WHEEL_INFODIR}/WHEEL
+${PYSITELIB}/${WHEEL_INFODIR}/entry_points.txt
+${PYSITELIB}/${WHEEL_INFODIR}/licenses/LICENSE
+${PYSITELIB}/${WHEEL_INFODIR}/top_level.txt
 ${PYSITELIB}/kafka/__init__.py
 ${PYSITELIB}/kafka/__init__.pyc
 ${PYSITELIB}/kafka/__init__.pyo
+${PYSITELIB}/kafka/__main__.py
+${PYSITELIB}/kafka/__main__.pyc
+${PYSITELIB}/kafka/__main__.pyo
 ${PYSITELIB}/kafka/admin/__init__.py
 ${PYSITELIB}/kafka/admin/__init__.pyc
 ${PYSITELIB}/kafka/admin/__init__.pyo
+${PYSITELIB}/kafka/admin/__main__.py
+${PYSITELIB}/kafka/admin/__main__.pyc
+${PYSITELIB}/kafka/admin/__main__.pyo
+${PYSITELIB}/kafka/admin/_acls.py
+${PYSITELIB}/kafka/admin/_acls.pyc
+${PYSITELIB}/kafka/admin/_acls.pyo
+${PYSITELIB}/kafka/admin/_cluster.py
+${PYSITELIB}/kafka/admin/_cluster.pyc
+${PYSITELIB}/kafka/admin/_cluster.pyo
+${PYSITELIB}/kafka/admin/_configs.py
+${PYSITELIB}/kafka/admin/_configs.pyc
+${PYSITELIB}/kafka/admin/_configs.pyo
+${PYSITELIB}/kafka/admin/_groups.py
+${PYSITELIB}/kafka/admin/_groups.pyc
+${PYSITELIB}/kafka/admin/_groups.pyo
+${PYSITELIB}/kafka/admin/_partitions.py
+${PYSITELIB}/kafka/admin/_partitions.pyc
+${PYSITELIB}/kafka/admin/_partitions.pyo
+${PYSITELIB}/kafka/admin/_topics.py
+${PYSITELIB}/kafka/admin/_topics.pyc
+${PYSITELIB}/kafka/admin/_topics.pyo
+${PYSITELIB}/kafka/admin/_transactions.py
+${PYSITELIB}/kafka/admin/_transactions.pyc
+${PYSITELIB}/kafka/admin/_transactions.pyo
+${PYSITELIB}/kafka/admin/_users.py
+${PYSITELIB}/kafka/admin/_users.pyc
+${PYSITELIB}/kafka/admin/_users.pyo
 ${PYSITELIB}/kafka/admin/client.py
 ${PYSITELIB}/kafka/admin/client.pyc
 ${PYSITELIB}/kafka/admin/client.pyo
-${PYSITELIB}/kafka/admin/config_resource.py
-${PYSITELIB}/kafka/admin/config_resource.pyc
-${PYSITELIB}/kafka/admin/config_resource.pyo
-${PYSITELIB}/kafka/admin/new_partitions.py
-${PYSITELIB}/kafka/admin/new_partitions.pyc
-${PYSITELIB}/kafka/admin/new_partitions.pyo
-${PYSITELIB}/kafka/admin/new_topic.py
-${PYSITELIB}/kafka/admin/new_topic.pyc
-${PYSITELIB}/kafka/admin/new_topic.pyo
-${PYSITELIB}/kafka/client.py
-${PYSITELIB}/kafka/client.pyc
-${PYSITELIB}/kafka/client.pyo
-${PYSITELIB}/kafka/client_async.py
-${PYSITELIB}/kafka/client_async.pyc
-${PYSITELIB}/kafka/client_async.pyo
+${PYSITELIB}/kafka/benchmarks/__init__.py
+${PYSITELIB}/kafka/benchmarks/__init__.pyc
+${PYSITELIB}/kafka/benchmarks/__init__.pyo
+${PYSITELIB}/kafka/benchmarks/consumer_performance.py
+${PYSITELIB}/kafka/benchmarks/consumer_performance.pyc
+${PYSITELIB}/kafka/benchmarks/consumer_performance.pyo
+${PYSITELIB}/kafka/benchmarks/load_example.py
+${PYSITELIB}/kafka/benchmarks/load_example.pyc
+${PYSITELIB}/kafka/benchmarks/load_example.pyo
+${PYSITELIB}/kafka/benchmarks/producer_encode_path.py
+${PYSITELIB}/kafka/benchmarks/producer_encode_path.pyc
+${PYSITELIB}/kafka/benchmarks/producer_encode_path.pyo
+${PYSITELIB}/kafka/benchmarks/producer_performance.py
+${PYSITELIB}/kafka/benchmarks/producer_performance.pyc
+${PYSITELIB}/kafka/benchmarks/producer_performance.pyo
+${PYSITELIB}/kafka/benchmarks/profile_protocol.py
+${PYSITELIB}/kafka/benchmarks/profile_protocol.pyc
+${PYSITELIB}/kafka/benchmarks/profile_protocol.pyo
+${PYSITELIB}/kafka/benchmarks/protocol_old_vs_new.py
+${PYSITELIB}/kafka/benchmarks/protocol_old_vs_new.pyc
+${PYSITELIB}/kafka/benchmarks/protocol_old_vs_new.pyo
+${PYSITELIB}/kafka/benchmarks/record_batch_compose.py
+${PYSITELIB}/kafka/benchmarks/record_batch_compose.pyc
+${PYSITELIB}/kafka/benchmarks/record_batch_compose.pyo
+${PYSITELIB}/kafka/benchmarks/record_batch_read.py
+${PYSITELIB}/kafka/benchmarks/record_batch_read.pyc
+${PYSITELIB}/kafka/benchmarks/record_batch_read.pyo
+${PYSITELIB}/kafka/benchmarks/varint_speed.py
+${PYSITELIB}/kafka/benchmarks/varint_speed.pyc
+${PYSITELIB}/kafka/benchmarks/varint_speed.pyo
+${PYSITELIB}/kafka/cli/__init__.py
+${PYSITELIB}/kafka/cli/__init__.pyc
+${PYSITELIB}/kafka/cli/__init__.pyo
+${PYSITELIB}/kafka/cli/admin/__init__.py
+${PYSITELIB}/kafka/cli/admin/__init__.pyc
+${PYSITELIB}/kafka/cli/admin/__init__.pyo
+${PYSITELIB}/kafka/cli/admin/acls/__init__.py
+${PYSITELIB}/kafka/cli/admin/acls/__init__.pyc
+${PYSITELIB}/kafka/cli/admin/acls/__init__.pyo
+${PYSITELIB}/kafka/cli/admin/acls/common.py
+${PYSITELIB}/kafka/cli/admin/acls/common.pyc
+${PYSITELIB}/kafka/cli/admin/acls/common.pyo
+${PYSITELIB}/kafka/cli/admin/acls/create.py
+${PYSITELIB}/kafka/cli/admin/acls/create.pyc
+${PYSITELIB}/kafka/cli/admin/acls/create.pyo
+${PYSITELIB}/kafka/cli/admin/acls/delete.py
+${PYSITELIB}/kafka/cli/admin/acls/delete.pyc
+${PYSITELIB}/kafka/cli/admin/acls/delete.pyo
+${PYSITELIB}/kafka/cli/admin/acls/describe.py
+${PYSITELIB}/kafka/cli/admin/acls/describe.pyc
+${PYSITELIB}/kafka/cli/admin/acls/describe.pyo
+${PYSITELIB}/kafka/cli/admin/cluster/__init__.py
+${PYSITELIB}/kafka/cli/admin/cluster/__init__.pyc
+${PYSITELIB}/kafka/cli/admin/cluster/__init__.pyo
+${PYSITELIB}/kafka/cli/admin/cluster/describe.py
+${PYSITELIB}/kafka/cli/admin/cluster/describe.pyc
+${PYSITELIB}/kafka/cli/admin/cluster/describe.pyo
+${PYSITELIB}/kafka/cli/admin/cluster/describe_quorum.py
+${PYSITELIB}/kafka/cli/admin/cluster/describe_quorum.pyc
+${PYSITELIB}/kafka/cli/admin/cluster/describe_quorum.pyo
+${PYSITELIB}/kafka/cli/admin/cluster/features.py
+${PYSITELIB}/kafka/cli/admin/cluster/features.pyc
+${PYSITELIB}/kafka/cli/admin/cluster/features.pyo
+${PYSITELIB}/kafka/cli/admin/cluster/log_dirs.py
+${PYSITELIB}/kafka/cli/admin/cluster/log_dirs.pyc
+${PYSITELIB}/kafka/cli/admin/cluster/log_dirs.pyo
+${PYSITELIB}/kafka/cli/admin/cluster/versions.py
+${PYSITELIB}/kafka/cli/admin/cluster/versions.pyc
+${PYSITELIB}/kafka/cli/admin/cluster/versions.pyo
+${PYSITELIB}/kafka/cli/admin/configs/__init__.py
+${PYSITELIB}/kafka/cli/admin/configs/__init__.pyc
+${PYSITELIB}/kafka/cli/admin/configs/__init__.pyo
+${PYSITELIB}/kafka/cli/admin/configs/alter.py
+${PYSITELIB}/kafka/cli/admin/configs/alter.pyc
+${PYSITELIB}/kafka/cli/admin/configs/alter.pyo
+${PYSITELIB}/kafka/cli/admin/configs/common.py
+${PYSITELIB}/kafka/cli/admin/configs/common.pyc
+${PYSITELIB}/kafka/cli/admin/configs/common.pyo
+${PYSITELIB}/kafka/cli/admin/configs/describe.py
+${PYSITELIB}/kafka/cli/admin/configs/describe.pyc
+${PYSITELIB}/kafka/cli/admin/configs/describe.pyo
+${PYSITELIB}/kafka/cli/admin/configs/list.py
+${PYSITELIB}/kafka/cli/admin/configs/list.pyc
+${PYSITELIB}/kafka/cli/admin/configs/list.pyo
+${PYSITELIB}/kafka/cli/admin/configs/reset.py
+${PYSITELIB}/kafka/cli/admin/configs/reset.pyc
+${PYSITELIB}/kafka/cli/admin/configs/reset.pyo
+${PYSITELIB}/kafka/cli/admin/groups/__init__.py
+${PYSITELIB}/kafka/cli/admin/groups/__init__.pyc
+${PYSITELIB}/kafka/cli/admin/groups/__init__.pyo
+${PYSITELIB}/kafka/cli/admin/groups/alter_offsets.py
+${PYSITELIB}/kafka/cli/admin/groups/alter_offsets.pyc
+${PYSITELIB}/kafka/cli/admin/groups/alter_offsets.pyo
+${PYSITELIB}/kafka/cli/admin/groups/delete.py
+${PYSITELIB}/kafka/cli/admin/groups/delete.pyc
+${PYSITELIB}/kafka/cli/admin/groups/delete.pyo
+${PYSITELIB}/kafka/cli/admin/groups/delete_offsets.py
+${PYSITELIB}/kafka/cli/admin/groups/delete_offsets.pyc
+${PYSITELIB}/kafka/cli/admin/groups/delete_offsets.pyo
+${PYSITELIB}/kafka/cli/admin/groups/describe.py
+${PYSITELIB}/kafka/cli/admin/groups/describe.pyc
+${PYSITELIB}/kafka/cli/admin/groups/describe.pyo
+${PYSITELIB}/kafka/cli/admin/groups/list.py
+${PYSITELIB}/kafka/cli/admin/groups/list.pyc
+${PYSITELIB}/kafka/cli/admin/groups/list.pyo
+${PYSITELIB}/kafka/cli/admin/groups/list_offsets.py
+${PYSITELIB}/kafka/cli/admin/groups/list_offsets.pyc
+${PYSITELIB}/kafka/cli/admin/groups/list_offsets.pyo
+${PYSITELIB}/kafka/cli/admin/groups/remove_members.py
+${PYSITELIB}/kafka/cli/admin/groups/remove_members.pyc
+${PYSITELIB}/kafka/cli/admin/groups/remove_members.pyo
+${PYSITELIB}/kafka/cli/admin/groups/reset_offsets.py
+${PYSITELIB}/kafka/cli/admin/groups/reset_offsets.pyc
+${PYSITELIB}/kafka/cli/admin/groups/reset_offsets.pyo
+${PYSITELIB}/kafka/cli/admin/partitions/__init__.py
+${PYSITELIB}/kafka/cli/admin/partitions/__init__.pyc
+${PYSITELIB}/kafka/cli/admin/partitions/__init__.pyo
+${PYSITELIB}/kafka/cli/admin/partitions/alter_reassignments.py
+${PYSITELIB}/kafka/cli/admin/partitions/alter_reassignments.pyc
+${PYSITELIB}/kafka/cli/admin/partitions/alter_reassignments.pyo
+${PYSITELIB}/kafka/cli/admin/partitions/create.py
+${PYSITELIB}/kafka/cli/admin/partitions/create.pyc
+${PYSITELIB}/kafka/cli/admin/partitions/create.pyo
+${PYSITELIB}/kafka/cli/admin/partitions/delete_records.py
+${PYSITELIB}/kafka/cli/admin/partitions/delete_records.pyc
+${PYSITELIB}/kafka/cli/admin/partitions/delete_records.pyo
+${PYSITELIB}/kafka/cli/admin/partitions/describe.py
+${PYSITELIB}/kafka/cli/admin/partitions/describe.pyc
+${PYSITELIB}/kafka/cli/admin/partitions/describe.pyo
+${PYSITELIB}/kafka/cli/admin/partitions/elect_leaders.py
+${PYSITELIB}/kafka/cli/admin/partitions/elect_leaders.pyc
+${PYSITELIB}/kafka/cli/admin/partitions/elect_leaders.pyo
+${PYSITELIB}/kafka/cli/admin/partitions/list_offsets.py
+${PYSITELIB}/kafka/cli/admin/partitions/list_offsets.pyc
+${PYSITELIB}/kafka/cli/admin/partitions/list_offsets.pyo
+${PYSITELIB}/kafka/cli/admin/partitions/list_reassignments.py
+${PYSITELIB}/kafka/cli/admin/partitions/list_reassignments.pyc
+${PYSITELIB}/kafka/cli/admin/partitions/list_reassignments.pyo
+${PYSITELIB}/kafka/cli/admin/topics/__init__.py
+${PYSITELIB}/kafka/cli/admin/topics/__init__.pyc
+${PYSITELIB}/kafka/cli/admin/topics/__init__.pyo
+${PYSITELIB}/kafka/cli/admin/topics/create.py
+${PYSITELIB}/kafka/cli/admin/topics/create.pyc
+${PYSITELIB}/kafka/cli/admin/topics/create.pyo
+${PYSITELIB}/kafka/cli/admin/topics/delete.py
+${PYSITELIB}/kafka/cli/admin/topics/delete.pyc
+${PYSITELIB}/kafka/cli/admin/topics/delete.pyo
+${PYSITELIB}/kafka/cli/admin/topics/describe.py
+${PYSITELIB}/kafka/cli/admin/topics/describe.pyc
+${PYSITELIB}/kafka/cli/admin/topics/describe.pyo
+${PYSITELIB}/kafka/cli/admin/topics/list.py
+${PYSITELIB}/kafka/cli/admin/topics/list.pyc
+${PYSITELIB}/kafka/cli/admin/topics/list.pyo
+${PYSITELIB}/kafka/cli/admin/transactions/__init__.py
+${PYSITELIB}/kafka/cli/admin/transactions/__init__.pyc
+${PYSITELIB}/kafka/cli/admin/transactions/__init__.pyo
+${PYSITELIB}/kafka/cli/admin/transactions/abort.py
+${PYSITELIB}/kafka/cli/admin/transactions/abort.pyc
+${PYSITELIB}/kafka/cli/admin/transactions/abort.pyo
+${PYSITELIB}/kafka/cli/admin/transactions/describe.py
+${PYSITELIB}/kafka/cli/admin/transactions/describe.pyc
+${PYSITELIB}/kafka/cli/admin/transactions/describe.pyo
+${PYSITELIB}/kafka/cli/admin/transactions/describe_producers.py
+${PYSITELIB}/kafka/cli/admin/transactions/describe_producers.pyc
+${PYSITELIB}/kafka/cli/admin/transactions/describe_producers.pyo
+${PYSITELIB}/kafka/cli/admin/transactions/find_hanging.py
+${PYSITELIB}/kafka/cli/admin/transactions/find_hanging.pyc
+${PYSITELIB}/kafka/cli/admin/transactions/find_hanging.pyo
+${PYSITELIB}/kafka/cli/admin/transactions/list.py
+${PYSITELIB}/kafka/cli/admin/transactions/list.pyc
+${PYSITELIB}/kafka/cli/admin/transactions/list.pyo
+${PYSITELIB}/kafka/cli/admin/users/__init__.py
+${PYSITELIB}/kafka/cli/admin/users/__init__.pyc
+${PYSITELIB}/kafka/cli/admin/users/__init__.pyo
+${PYSITELIB}/kafka/cli/admin/users/alter_user_scram_credentials.py
+${PYSITELIB}/kafka/cli/admin/users/alter_user_scram_credentials.pyc
+${PYSITELIB}/kafka/cli/admin/users/alter_user_scram_credentials.pyo
+${PYSITELIB}/kafka/cli/admin/users/describe_user_scram_credentials.py
+${PYSITELIB}/kafka/cli/admin/users/describe_user_scram_credentials.pyc
+${PYSITELIB}/kafka/cli/admin/users/describe_user_scram_credentials.pyo
+${PYSITELIB}/kafka/cli/common.py
+${PYSITELIB}/kafka/cli/common.pyc
+${PYSITELIB}/kafka/cli/common.pyo
+${PYSITELIB}/kafka/cli/consumer/__init__.py
+${PYSITELIB}/kafka/cli/consumer/__init__.pyc
+${PYSITELIB}/kafka/cli/consumer/__init__.pyo
+${PYSITELIB}/kafka/cli/producer/__init__.py
+${PYSITELIB}/kafka/cli/producer/__init__.pyc
+${PYSITELIB}/kafka/cli/producer/__init__.pyo
 ${PYSITELIB}/kafka/cluster.py
 ${PYSITELIB}/kafka/cluster.pyc
 ${PYSITELIB}/kafka/cluster.pyo
 ${PYSITELIB}/kafka/codec.py
 ${PYSITELIB}/kafka/codec.pyc
 ${PYSITELIB}/kafka/codec.pyo
-${PYSITELIB}/kafka/common.py
-${PYSITELIB}/kafka/common.pyc
-${PYSITELIB}/kafka/common.pyo
-${PYSITELIB}/kafka/conn.py
-${PYSITELIB}/kafka/conn.pyc
-${PYSITELIB}/kafka/conn.pyo
 ${PYSITELIB}/kafka/consumer/__init__.py
 ${PYSITELIB}/kafka/consumer/__init__.pyc
 ${PYSITELIB}/kafka/consumer/__init__.pyo
-${PYSITELIB}/kafka/consumer/base.py
-${PYSITELIB}/kafka/consumer/base.pyc
-${PYSITELIB}/kafka/consumer/base.pyo
+${PYSITELIB}/kafka/consumer/__main__.py
+${PYSITELIB}/kafka/consumer/__main__.pyc
+${PYSITELIB}/kafka/consumer/__main__.pyo
 ${PYSITELIB}/kafka/consumer/fetcher.py
 ${PYSITELIB}/kafka/consumer/fetcher.pyc
 ${PYSITELIB}/kafka/consumer/fetcher.pyo
 ${PYSITELIB}/kafka/consumer/group.py
 ${PYSITELIB}/kafka/consumer/group.pyc
 ${PYSITELIB}/kafka/consumer/group.pyo
-${PYSITELIB}/kafka/consumer/multiprocess.py
-${PYSITELIB}/kafka/consumer/multiprocess.pyc
-${PYSITELIB}/kafka/consumer/multiprocess.pyo
-${PYSITELIB}/kafka/consumer/simple.py
-${PYSITELIB}/kafka/consumer/simple.pyc
-${PYSITELIB}/kafka/consumer/simple.pyo
 ${PYSITELIB}/kafka/consumer/subscription_state.py
 ${PYSITELIB}/kafka/consumer/subscription_state.pyc
 ${PYSITELIB}/kafka/consumer/subscription_state.pyo
-${PYSITELIB}/kafka/context.py
-${PYSITELIB}/kafka/context.pyc
-${PYSITELIB}/kafka/context.pyo
 ${PYSITELIB}/kafka/coordinator/__init__.py
 ${PYSITELIB}/kafka/coordinator/__init__.pyc
 ${PYSITELIB}/kafka/coordinator/__init__.pyo
@@ -72,12 +264,31 @@ ${PYSITELIB}/kafka/coordinator/assignors
 ${PYSITELIB}/kafka/coordinator/assignors/abstract.py
 ${PYSITELIB}/kafka/coordinator/assignors/abstract.pyc
 ${PYSITELIB}/kafka/coordinator/assignors/abstract.pyo
+${PYSITELIB}/kafka/coordinator/assignors/cooperative_sticky.py
+${PYSITELIB}/kafka/coordinator/assignors/cooperative_sticky.pyc
+${PYSITELIB}/kafka/coordinator/assignors/cooperative_sticky.pyo
 ${PYSITELIB}/kafka/coordinator/assignors/range.py
 ${PYSITELIB}/kafka/coordinator/assignors/range.pyc
 ${PYSITELIB}/kafka/coordinator/assignors/range.pyo
 ${PYSITELIB}/kafka/coordinator/assignors/roundrobin.py
 ${PYSITELIB}/kafka/coordinator/assignors/roundrobin.pyc
 ${PYSITELIB}/kafka/coordinator/assignors/roundrobin.pyo
+${PYSITELIB}/kafka/coordinator/assignors/sticky/StickyAssignorUserData.json
+${PYSITELIB}/kafka/coordinator/assignors/sticky/__init__.py
+${PYSITELIB}/kafka/coordinator/assignors/sticky/__init__.pyc
+${PYSITELIB}/kafka/coordinator/assignors/sticky/__init__.pyo
+${PYSITELIB}/kafka/coordinator/assignors/sticky/partition_movements.py
+${PYSITELIB}/kafka/coordinator/assignors/sticky/partition_movements.pyc
+${PYSITELIB}/kafka/coordinator/assignors/sticky/partition_movements.pyo
+${PYSITELIB}/kafka/coordinator/assignors/sticky/sorted_set.py
+${PYSITELIB}/kafka/coordinator/assignors/sticky/sorted_set.pyc
+${PYSITELIB}/kafka/coordinator/assignors/sticky/sorted_set.pyo
+${PYSITELIB}/kafka/coordinator/assignors/sticky/sticky_assignor.py
+${PYSITELIB}/kafka/coordinator/assignors/sticky/sticky_assignor.pyc
+${PYSITELIB}/kafka/coordinator/assignors/sticky/sticky_assignor.pyo
+${PYSITELIB}/kafka/coordinator/assignors/sticky/user_data.py
+${PYSITELIB}/kafka/coordinator/assignors/sticky/user_data.pyc
+${PYSITELIB}/kafka/coordinator/assignors/sticky/user_data.pyo
 ${PYSITELIB}/kafka/coordinator/base.py
 ${PYSITELIB}/kafka/coordinator/base.pyc
 ${PYSITELIB}/kafka/coordinator/base.pyo
@@ -87,9 +298,9 @@ ${PYSITELIB}/kafka/coordinator/consumer.
 ${PYSITELIB}/kafka/coordinator/heartbeat.py
 ${PYSITELIB}/kafka/coordinator/heartbeat.pyc
 ${PYSITELIB}/kafka/coordinator/heartbeat.pyo
-${PYSITELIB}/kafka/coordinator/protocol.py
-${PYSITELIB}/kafka/coordinator/protocol.pyc
-${PYSITELIB}/kafka/coordinator/protocol.pyo
+${PYSITELIB}/kafka/coordinator/subscription.py
+${PYSITELIB}/kafka/coordinator/subscription.pyc
+${PYSITELIB}/kafka/coordinator/subscription.pyo
 ${PYSITELIB}/kafka/errors.py
 ${PYSITELIB}/kafka/errors.pyc
 ${PYSITELIB}/kafka/errors.pyo
@@ -168,99 +379,432 @@ ${PYSITELIB}/kafka/metrics/stats/sensor.
 ${PYSITELIB}/kafka/metrics/stats/total.py
 ${PYSITELIB}/kafka/metrics/stats/total.pyc
 ${PYSITELIB}/kafka/metrics/stats/total.pyo
+${PYSITELIB}/kafka/net/__init__.py
+${PYSITELIB}/kafka/net/__init__.pyc
+${PYSITELIB}/kafka/net/__init__.pyo
+${PYSITELIB}/kafka/net/compat.py
+${PYSITELIB}/kafka/net/compat.pyc
+${PYSITELIB}/kafka/net/compat.pyo
+${PYSITELIB}/kafka/net/connection.py
+${PYSITELIB}/kafka/net/connection.pyc
+${PYSITELIB}/kafka/net/connection.pyo
+${PYSITELIB}/kafka/net/http_connect.py
+${PYSITELIB}/kafka/net/http_connect.pyc
+${PYSITELIB}/kafka/net/http_connect.pyo
+${PYSITELIB}/kafka/net/inet.py
+${PYSITELIB}/kafka/net/inet.pyc
+${PYSITELIB}/kafka/net/inet.pyo
+${PYSITELIB}/kafka/net/manager.py
+${PYSITELIB}/kafka/net/manager.pyc
+${PYSITELIB}/kafka/net/manager.pyo
+${PYSITELIB}/kafka/net/metrics.py
+${PYSITELIB}/kafka/net/metrics.pyc
+${PYSITELIB}/kafka/net/metrics.pyo
+${PYSITELIB}/kafka/net/sasl/__init__.py
+${PYSITELIB}/kafka/net/sasl/__init__.pyc
+${PYSITELIB}/kafka/net/sasl/__init__.pyo
+${PYSITELIB}/kafka/net/sasl/abc.py
+${PYSITELIB}/kafka/net/sasl/abc.pyc
+${PYSITELIB}/kafka/net/sasl/abc.pyo
+${PYSITELIB}/kafka/net/sasl/gssapi.py
+${PYSITELIB}/kafka/net/sasl/gssapi.pyc
+${PYSITELIB}/kafka/net/sasl/gssapi.pyo
+${PYSITELIB}/kafka/net/sasl/msk.py
+${PYSITELIB}/kafka/net/sasl/msk.pyc
+${PYSITELIB}/kafka/net/sasl/msk.pyo
+${PYSITELIB}/kafka/net/sasl/oauth.py
+${PYSITELIB}/kafka/net/sasl/oauth.pyc
+${PYSITELIB}/kafka/net/sasl/oauth.pyo
+${PYSITELIB}/kafka/net/sasl/plain.py
+${PYSITELIB}/kafka/net/sasl/plain.pyc
+${PYSITELIB}/kafka/net/sasl/plain.pyo
+${PYSITELIB}/kafka/net/sasl/scram.py
+${PYSITELIB}/kafka/net/sasl/scram.pyc
+${PYSITELIB}/kafka/net/sasl/scram.pyo
+${PYSITELIB}/kafka/net/sasl/sspi.py
+${PYSITELIB}/kafka/net/sasl/sspi.pyc
+${PYSITELIB}/kafka/net/sasl/sspi.pyo
+${PYSITELIB}/kafka/net/selector.py
+${PYSITELIB}/kafka/net/selector.pyc
+${PYSITELIB}/kafka/net/selector.pyo
+${PYSITELIB}/kafka/net/socks5.py
+${PYSITELIB}/kafka/net/socks5.pyc
+${PYSITELIB}/kafka/net/socks5.pyo
+${PYSITELIB}/kafka/net/transport.py
+${PYSITELIB}/kafka/net/transport.pyc
+${PYSITELIB}/kafka/net/transport.pyo
+${PYSITELIB}/kafka/net/wakeup_notifier.py
+${PYSITELIB}/kafka/net/wakeup_notifier.pyc
+${PYSITELIB}/kafka/net/wakeup_notifier.pyo
 ${PYSITELIB}/kafka/partitioner/__init__.py
 ${PYSITELIB}/kafka/partitioner/__init__.pyc
 ${PYSITELIB}/kafka/partitioner/__init__.pyo
-${PYSITELIB}/kafka/partitioner/base.py
-${PYSITELIB}/kafka/partitioner/base.pyc
-${PYSITELIB}/kafka/partitioner/base.pyo
+${PYSITELIB}/kafka/partitioner/abc.py
+${PYSITELIB}/kafka/partitioner/abc.pyc
+${PYSITELIB}/kafka/partitioner/abc.pyo
 ${PYSITELIB}/kafka/partitioner/default.py
 ${PYSITELIB}/kafka/partitioner/default.pyc
 ${PYSITELIB}/kafka/partitioner/default.pyo
-${PYSITELIB}/kafka/partitioner/hashed.py
-${PYSITELIB}/kafka/partitioner/hashed.pyc
-${PYSITELIB}/kafka/partitioner/hashed.pyo
-${PYSITELIB}/kafka/partitioner/roundrobin.py
-${PYSITELIB}/kafka/partitioner/roundrobin.pyc
-${PYSITELIB}/kafka/partitioner/roundrobin.pyo
+${PYSITELIB}/kafka/partitioner/sticky.py
+${PYSITELIB}/kafka/partitioner/sticky.pyc
+${PYSITELIB}/kafka/partitioner/sticky.pyo
 ${PYSITELIB}/kafka/producer/__init__.py
 ${PYSITELIB}/kafka/producer/__init__.pyc
 ${PYSITELIB}/kafka/producer/__init__.pyo
-${PYSITELIB}/kafka/producer/base.py
-${PYSITELIB}/kafka/producer/base.pyc
-${PYSITELIB}/kafka/producer/base.pyo
-${PYSITELIB}/kafka/producer/buffer.py
-${PYSITELIB}/kafka/producer/buffer.pyc
-${PYSITELIB}/kafka/producer/buffer.pyo
+${PYSITELIB}/kafka/producer/__main__.py
+${PYSITELIB}/kafka/producer/__main__.pyc
+${PYSITELIB}/kafka/producer/__main__.pyo
 ${PYSITELIB}/kafka/producer/future.py
 ${PYSITELIB}/kafka/producer/future.pyc
 ${PYSITELIB}/kafka/producer/future.pyo
 ${PYSITELIB}/kafka/producer/kafka.py
 ${PYSITELIB}/kafka/producer/kafka.pyc
 ${PYSITELIB}/kafka/producer/kafka.pyo
-${PYSITELIB}/kafka/producer/keyed.py
-${PYSITELIB}/kafka/producer/keyed.pyc
-${PYSITELIB}/kafka/producer/keyed.pyo
+${PYSITELIB}/kafka/producer/producer_batch.py
+${PYSITELIB}/kafka/producer/producer_batch.pyc
+${PYSITELIB}/kafka/producer/producer_batch.pyo
 ${PYSITELIB}/kafka/producer/record_accumulator.py
 ${PYSITELIB}/kafka/producer/record_accumulator.pyc
 ${PYSITELIB}/kafka/producer/record_accumulator.pyo
 ${PYSITELIB}/kafka/producer/sender.py
 ${PYSITELIB}/kafka/producer/sender.pyc
 ${PYSITELIB}/kafka/producer/sender.pyo
-${PYSITELIB}/kafka/producer/simple.py
-${PYSITELIB}/kafka/producer/simple.pyc
-${PYSITELIB}/kafka/producer/simple.pyo
+${PYSITELIB}/kafka/producer/transaction_manager.py
+${PYSITELIB}/kafka/producer/transaction_manager.pyc
+${PYSITELIB}/kafka/producer/transaction_manager.pyo
 ${PYSITELIB}/kafka/protocol/__init__.py
 ${PYSITELIB}/kafka/protocol/__init__.pyc
 ${PYSITELIB}/kafka/protocol/__init__.pyo
-${PYSITELIB}/kafka/protocol/abstract.py
-${PYSITELIB}/kafka/protocol/abstract.pyc
-${PYSITELIB}/kafka/protocol/abstract.pyo
-${PYSITELIB}/kafka/protocol/admin.py
-${PYSITELIB}/kafka/protocol/admin.pyc
-${PYSITELIB}/kafka/protocol/admin.pyo
-${PYSITELIB}/kafka/protocol/api.py
-${PYSITELIB}/kafka/protocol/api.pyc
-${PYSITELIB}/kafka/protocol/api.pyo
-${PYSITELIB}/kafka/protocol/commit.py
-${PYSITELIB}/kafka/protocol/commit.pyc
-${PYSITELIB}/kafka/protocol/commit.pyo
-${PYSITELIB}/kafka/protocol/fetch.py
-${PYSITELIB}/kafka/protocol/fetch.pyc
-${PYSITELIB}/kafka/protocol/fetch.pyo
+${PYSITELIB}/kafka/protocol/admin/__init__.py
+${PYSITELIB}/kafka/protocol/admin/__init__.pyc
+${PYSITELIB}/kafka/protocol/admin/__init__.pyo
+${PYSITELIB}/kafka/protocol/admin/acl.py
+${PYSITELIB}/kafka/protocol/admin/acl.pyc
+${PYSITELIB}/kafka/protocol/admin/acl.pyi
+${PYSITELIB}/kafka/protocol/admin/acl.pyo
+${PYSITELIB}/kafka/protocol/admin/client_quotas.py
+${PYSITELIB}/kafka/protocol/admin/client_quotas.pyc
+${PYSITELIB}/kafka/protocol/admin/client_quotas.pyi
+${PYSITELIB}/kafka/protocol/admin/client_quotas.pyo
+${PYSITELIB}/kafka/protocol/admin/cluster.py
+${PYSITELIB}/kafka/protocol/admin/cluster.pyc
+${PYSITELIB}/kafka/protocol/admin/cluster.pyi
+${PYSITELIB}/kafka/protocol/admin/cluster.pyo
+${PYSITELIB}/kafka/protocol/admin/configs.py
+${PYSITELIB}/kafka/protocol/admin/configs.pyc
+${PYSITELIB}/kafka/protocol/admin/configs.pyi
+${PYSITELIB}/kafka/protocol/admin/configs.pyo
+${PYSITELIB}/kafka/protocol/admin/groups.py
+${PYSITELIB}/kafka/protocol/admin/groups.pyc
+${PYSITELIB}/kafka/protocol/admin/groups.pyi
+${PYSITELIB}/kafka/protocol/admin/groups.pyo
+${PYSITELIB}/kafka/protocol/admin/topics.py
+${PYSITELIB}/kafka/protocol/admin/topics.pyc
+${PYSITELIB}/kafka/protocol/admin/topics.pyi
+${PYSITELIB}/kafka/protocol/admin/topics.pyo
+${PYSITELIB}/kafka/protocol/admin/transactions.py
+${PYSITELIB}/kafka/protocol/admin/transactions.pyc
+${PYSITELIB}/kafka/protocol/admin/transactions.pyi
+${PYSITELIB}/kafka/protocol/admin/transactions.pyo
+${PYSITELIB}/kafka/protocol/admin/users.py
+${PYSITELIB}/kafka/protocol/admin/users.pyc
+${PYSITELIB}/kafka/protocol/admin/users.pyi
+${PYSITELIB}/kafka/protocol/admin/users.pyo
+${PYSITELIB}/kafka/protocol/api_data.py
+${PYSITELIB}/kafka/protocol/api_data.pyc
+${PYSITELIB}/kafka/protocol/api_data.pyo
+${PYSITELIB}/kafka/protocol/api_header.py
+${PYSITELIB}/kafka/protocol/api_header.pyc
+${PYSITELIB}/kafka/protocol/api_header.pyo
+${PYSITELIB}/kafka/protocol/api_key.py
+${PYSITELIB}/kafka/protocol/api_key.pyc
+${PYSITELIB}/kafka/protocol/api_key.pyo
+${PYSITELIB}/kafka/protocol/api_message.py
+${PYSITELIB}/kafka/protocol/api_message.pyc
+${PYSITELIB}/kafka/protocol/api_message.pyo
+${PYSITELIB}/kafka/protocol/broker_version_data.py
+${PYSITELIB}/kafka/protocol/broker_version_data.pyc
+${PYSITELIB}/kafka/protocol/broker_version_data.pyo
+${PYSITELIB}/kafka/protocol/consumer/__init__.py
+${PYSITELIB}/kafka/protocol/consumer/__init__.pyc
+${PYSITELIB}/kafka/protocol/consumer/__init__.pyo
+${PYSITELIB}/kafka/protocol/consumer/fetch.py
+${PYSITELIB}/kafka/protocol/consumer/fetch.pyc
+${PYSITELIB}/kafka/protocol/consumer/fetch.pyi
+${PYSITELIB}/kafka/protocol/consumer/fetch.pyo
+${PYSITELIB}/kafka/protocol/consumer/group.py
+${PYSITELIB}/kafka/protocol/consumer/group.pyc
+${PYSITELIB}/kafka/protocol/consumer/group.pyi
+${PYSITELIB}/kafka/protocol/consumer/group.pyo
+${PYSITELIB}/kafka/protocol/consumer/metadata.py
+${PYSITELIB}/kafka/protocol/consumer/metadata.pyc
+${PYSITELIB}/kafka/protocol/consumer/metadata.pyi
+${PYSITELIB}/kafka/protocol/consumer/metadata.pyo
+${PYSITELIB}/kafka/protocol/consumer/offsets.py
+${PYSITELIB}/kafka/protocol/consumer/offsets.pyc
+${PYSITELIB}/kafka/protocol/consumer/offsets.pyi
+${PYSITELIB}/kafka/protocol/consumer/offsets.pyo
+${PYSITELIB}/kafka/protocol/data_container.py
+${PYSITELIB}/kafka/protocol/data_container.pyc
+${PYSITELIB}/kafka/protocol/data_container.pyo
 ${PYSITELIB}/kafka/protocol/frame.py
 ${PYSITELIB}/kafka/protocol/frame.pyc
 ${PYSITELIB}/kafka/protocol/frame.pyo
-${PYSITELIB}/kafka/protocol/group.py
-${PYSITELIB}/kafka/protocol/group.pyc
-${PYSITELIB}/kafka/protocol/group.pyo
-${PYSITELIB}/kafka/protocol/legacy.py
-${PYSITELIB}/kafka/protocol/legacy.pyc
-${PYSITELIB}/kafka/protocol/legacy.pyo
-${PYSITELIB}/kafka/protocol/message.py
-${PYSITELIB}/kafka/protocol/message.pyc
-${PYSITELIB}/kafka/protocol/message.pyo
-${PYSITELIB}/kafka/protocol/metadata.py
-${PYSITELIB}/kafka/protocol/metadata.pyc
-${PYSITELIB}/kafka/protocol/metadata.pyo
-${PYSITELIB}/kafka/protocol/offset.py
-${PYSITELIB}/kafka/protocol/offset.pyc
-${PYSITELIB}/kafka/protocol/offset.pyo
+${PYSITELIB}/kafka/protocol/generate_stubs.py
+${PYSITELIB}/kafka/protocol/generate_stubs.pyc
+${PYSITELIB}/kafka/protocol/generate_stubs.pyo
+${PYSITELIB}/kafka/protocol/metadata/__init__.py
+${PYSITELIB}/kafka/protocol/metadata/__init__.pyc
+${PYSITELIB}/kafka/protocol/metadata/__init__.pyo
+${PYSITELIB}/kafka/protocol/metadata/api_versions.py
+${PYSITELIB}/kafka/protocol/metadata/api_versions.pyc
+${PYSITELIB}/kafka/protocol/metadata/api_versions.pyi
+${PYSITELIB}/kafka/protocol/metadata/api_versions.pyo
+${PYSITELIB}/kafka/protocol/metadata/find_coordinator.py
+${PYSITELIB}/kafka/protocol/metadata/find_coordinator.pyc
+${PYSITELIB}/kafka/protocol/metadata/find_coordinator.pyi
+${PYSITELIB}/kafka/protocol/metadata/find_coordinator.pyo
+${PYSITELIB}/kafka/protocol/metadata/metadata.py
+${PYSITELIB}/kafka/protocol/metadata/metadata.pyc
+${PYSITELIB}/kafka/protocol/metadata/metadata.pyi
+${PYSITELIB}/kafka/protocol/metadata/metadata.pyo
+${PYSITELIB}/kafka/protocol/old/__init__.py
+${PYSITELIB}/kafka/protocol/old/__init__.pyc
+${PYSITELIB}/kafka/protocol/old/__init__.pyo
+${PYSITELIB}/kafka/protocol/old/abstract.py
+${PYSITELIB}/kafka/protocol/old/abstract.pyc
+${PYSITELIB}/kafka/protocol/old/abstract.pyo
+${PYSITELIB}/kafka/protocol/old/add_offsets_to_txn.py
+${PYSITELIB}/kafka/protocol/old/add_offsets_to_txn.pyc
+${PYSITELIB}/kafka/protocol/old/add_offsets_to_txn.pyo
+${PYSITELIB}/kafka/protocol/old/add_partitions_to_txn.py
+${PYSITELIB}/kafka/protocol/old/add_partitions_to_txn.pyc
+${PYSITELIB}/kafka/protocol/old/add_partitions_to_txn.pyo
+${PYSITELIB}/kafka/protocol/old/admin.py
+${PYSITELIB}/kafka/protocol/old/admin.pyc
+${PYSITELIB}/kafka/protocol/old/admin.pyo
+${PYSITELIB}/kafka/protocol/old/api.py
+${PYSITELIB}/kafka/protocol/old/api.pyc
+${PYSITELIB}/kafka/protocol/old/api.pyo
+${PYSITELIB}/kafka/protocol/old/api_versions.py
+${PYSITELIB}/kafka/protocol/old/api_versions.pyc
+${PYSITELIB}/kafka/protocol/old/api_versions.pyo
+${PYSITELIB}/kafka/protocol/old/commit.py
+${PYSITELIB}/kafka/protocol/old/commit.pyc
+${PYSITELIB}/kafka/protocol/old/commit.pyo
+${PYSITELIB}/kafka/protocol/old/consumer_protocol.py
+${PYSITELIB}/kafka/protocol/old/consumer_protocol.pyc
+${PYSITELIB}/kafka/protocol/old/consumer_protocol.pyo
+${PYSITELIB}/kafka/protocol/old/end_txn.py
+${PYSITELIB}/kafka/protocol/old/end_txn.pyc
+${PYSITELIB}/kafka/protocol/old/end_txn.pyo
+${PYSITELIB}/kafka/protocol/old/fetch.py
+${PYSITELIB}/kafka/protocol/old/fetch.pyc
+${PYSITELIB}/kafka/protocol/old/fetch.pyo
+${PYSITELIB}/kafka/protocol/old/find_coordinator.py
+${PYSITELIB}/kafka/protocol/old/find_coordinator.pyc
+${PYSITELIB}/kafka/protocol/old/find_coordinator.pyo
+${PYSITELIB}/kafka/protocol/old/group.py
+${PYSITELIB}/kafka/protocol/old/group.pyc
+${PYSITELIB}/kafka/protocol/old/group.pyo
+${PYSITELIB}/kafka/protocol/old/init_producer_id.py
+${PYSITELIB}/kafka/protocol/old/init_producer_id.pyc
+${PYSITELIB}/kafka/protocol/old/init_producer_id.pyo
+${PYSITELIB}/kafka/protocol/old/list_offsets.py
+${PYSITELIB}/kafka/protocol/old/list_offsets.pyc
+${PYSITELIB}/kafka/protocol/old/list_offsets.pyo
+${PYSITELIB}/kafka/protocol/old/metadata.py
+${PYSITELIB}/kafka/protocol/old/metadata.pyc
+${PYSITELIB}/kafka/protocol/old/metadata.pyo
+${PYSITELIB}/kafka/protocol/old/offset_for_leader_epoch.py
+${PYSITELIB}/kafka/protocol/old/offset_for_leader_epoch.pyc
+${PYSITELIB}/kafka/protocol/old/offset_for_leader_epoch.pyo
+${PYSITELIB}/kafka/protocol/old/produce.py
+${PYSITELIB}/kafka/protocol/old/produce.pyc
+${PYSITELIB}/kafka/protocol/old/produce.pyo
+${PYSITELIB}/kafka/protocol/old/sasl_authenticate.py
+${PYSITELIB}/kafka/protocol/old/sasl_authenticate.pyc
+${PYSITELIB}/kafka/protocol/old/sasl_authenticate.pyo
+${PYSITELIB}/kafka/protocol/old/sasl_handshake.py
+${PYSITELIB}/kafka/protocol/old/sasl_handshake.pyc
+${PYSITELIB}/kafka/protocol/old/sasl_handshake.pyo
+${PYSITELIB}/kafka/protocol/old/struct.py
+${PYSITELIB}/kafka/protocol/old/struct.pyc
+${PYSITELIB}/kafka/protocol/old/struct.pyo
+${PYSITELIB}/kafka/protocol/old/txn_offset_commit.py
+${PYSITELIB}/kafka/protocol/old/txn_offset_commit.pyc
+${PYSITELIB}/kafka/protocol/old/txn_offset_commit.pyo
+${PYSITELIB}/kafka/protocol/old/types.py
+${PYSITELIB}/kafka/protocol/old/types.pyc
+${PYSITELIB}/kafka/protocol/old/types.pyo
 ${PYSITELIB}/kafka/protocol/parser.py
 ${PYSITELIB}/kafka/protocol/parser.pyc
 ${PYSITELIB}/kafka/protocol/parser.pyo
-${PYSITELIB}/kafka/protocol/pickle.py
-${PYSITELIB}/kafka/protocol/pickle.pyc
-${PYSITELIB}/kafka/protocol/pickle.pyo
-${PYSITELIB}/kafka/protocol/produce.py
-${PYSITELIB}/kafka/protocol/produce.pyc
-${PYSITELIB}/kafka/protocol/produce.pyo
-${PYSITELIB}/kafka/protocol/struct.py
-${PYSITELIB}/kafka/protocol/struct.pyc
-${PYSITELIB}/kafka/protocol/struct.pyo
-${PYSITELIB}/kafka/protocol/types.py
-${PYSITELIB}/kafka/protocol/types.pyc
-${PYSITELIB}/kafka/protocol/types.pyo
+${PYSITELIB}/kafka/protocol/producer/__init__.py
+${PYSITELIB}/kafka/protocol/producer/__init__.pyc
+${PYSITELIB}/kafka/protocol/producer/__init__.pyo
+${PYSITELIB}/kafka/protocol/producer/produce.py
+${PYSITELIB}/kafka/protocol/producer/produce.pyc
+${PYSITELIB}/kafka/protocol/producer/produce.pyi
+${PYSITELIB}/kafka/protocol/producer/produce.pyo
+${PYSITELIB}/kafka/protocol/producer/transaction.py
+${PYSITELIB}/kafka/protocol/producer/transaction.pyc
+${PYSITELIB}/kafka/protocol/producer/transaction.pyi
+${PYSITELIB}/kafka/protocol/producer/transaction.pyo
+${PYSITELIB}/kafka/protocol/sasl.py
+${PYSITELIB}/kafka/protocol/sasl.pyc
+${PYSITELIB}/kafka/protocol/sasl.pyi
+${PYSITELIB}/kafka/protocol/sasl.pyo
+${PYSITELIB}/kafka/protocol/schemas/__init__.py
+${PYSITELIB}/kafka/protocol/schemas/__init__.pyc
+${PYSITELIB}/kafka/protocol/schemas/__init__.pyo
+${PYSITELIB}/kafka/protocol/schemas/fields/__init__.py
+${PYSITELIB}/kafka/protocol/schemas/fields/__init__.pyc
+${PYSITELIB}/kafka/protocol/schemas/fields/__init__.pyo
+${PYSITELIB}/kafka/protocol/schemas/fields/array.py
+${PYSITELIB}/kafka/protocol/schemas/fields/array.pyc
+${PYSITELIB}/kafka/protocol/schemas/fields/array.pyo
+${PYSITELIB}/kafka/protocol/schemas/fields/base.py
+${PYSITELIB}/kafka/protocol/schemas/fields/base.pyc
+${PYSITELIB}/kafka/protocol/schemas/fields/base.pyo
+${PYSITELIB}/kafka/protocol/schemas/fields/codecs/__init__.py
+${PYSITELIB}/kafka/protocol/schemas/fields/codecs/__init__.pyc
+${PYSITELIB}/kafka/protocol/schemas/fields/codecs/__init__.pyo
+${PYSITELIB}/kafka/protocol/schemas/fields/codecs/encode_buffer.py
+${PYSITELIB}/kafka/protocol/schemas/fields/codecs/encode_buffer.pyc
+${PYSITELIB}/kafka/protocol/schemas/fields/codecs/encode_buffer.pyo
+${PYSITELIB}/kafka/protocol/schemas/fields/codecs/tagged_fields.py
+${PYSITELIB}/kafka/protocol/schemas/fields/codecs/tagged_fields.pyc
+${PYSITELIB}/kafka/protocol/schemas/fields/codecs/tagged_fields.pyo
+${PYSITELIB}/kafka/protocol/schemas/fields/codecs/types.py
+${PYSITELIB}/kafka/protocol/schemas/fields/codecs/types.pyc
+${PYSITELIB}/kafka/protocol/schemas/fields/codecs/types.pyo
+${PYSITELIB}/kafka/protocol/schemas/fields/codegen.py
+${PYSITELIB}/kafka/protocol/schemas/fields/codegen.pyc
+${PYSITELIB}/kafka/protocol/schemas/fields/codegen.pyo
+${PYSITELIB}/kafka/protocol/schemas/fields/simple.py
+${PYSITELIB}/kafka/protocol/schemas/fields/simple.pyc
+${PYSITELIB}/kafka/protocol/schemas/fields/simple.pyo
+${PYSITELIB}/kafka/protocol/schemas/fields/struct.py
+${PYSITELIB}/kafka/protocol/schemas/fields/struct.pyc
+${PYSITELIB}/kafka/protocol/schemas/fields/struct.pyo
+${PYSITELIB}/kafka/protocol/schemas/fields/struct_array.py
+${PYSITELIB}/kafka/protocol/schemas/fields/struct_array.pyc
+${PYSITELIB}/kafka/protocol/schemas/fields/struct_array.pyo
+${PYSITELIB}/kafka/protocol/schemas/load_json.py
+${PYSITELIB}/kafka/protocol/schemas/load_json.pyc
+${PYSITELIB}/kafka/protocol/schemas/load_json.pyo
+${PYSITELIB}/kafka/protocol/schemas/resources/AddOffsetsToTxnRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AddOffsetsToTxnResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AddPartitionsToTxnRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AddPartitionsToTxnResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AlterClientQuotasRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AlterClientQuotasResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AlterConfigsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AlterConfigsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AlterPartitionReassignmentsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AlterPartitionReassignmentsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AlterReplicaLogDirsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AlterReplicaLogDirsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AlterUserScramCredentialsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/AlterUserScramCredentialsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ApiVersionsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ApiVersionsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ConsumerProtocolAssignment.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ConsumerProtocolSubscription.json
+${PYSITELIB}/kafka/protocol/schemas/resources/CreateAclsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/CreateAclsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/CreatePartitionsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/CreatePartitionsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/CreateTopicsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/CreateTopicsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DeleteAclsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DeleteAclsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DeleteGroupsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DeleteGroupsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DeleteRecordsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DeleteRecordsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DeleteTopicsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DeleteTopicsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeAclsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeAclsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeClientQuotasRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeClientQuotasResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeClusterRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeClusterResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeConfigsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeConfigsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeGroupsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeGroupsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeLogDirsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeLogDirsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeProducersRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeProducersResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeQuorumRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeQuorumResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeTopicPartitionsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeTopicPartitionsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeTransactionsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeTransactionsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeUserScramCredentialsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/DescribeUserScramCredentialsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ElectLeadersRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ElectLeadersResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/EndTxnRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/EndTxnResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/FetchRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/FetchResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/FindCoordinatorRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/FindCoordinatorResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/HeartbeatRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/HeartbeatResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/IncrementalAlterConfigsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/IncrementalAlterConfigsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/InitProducerIdRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/InitProducerIdResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/JoinGroupRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/JoinGroupResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/LeaveGroupRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/LeaveGroupResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ListConfigResourcesRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ListConfigResourcesResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ListGroupsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ListGroupsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ListOffsetsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ListOffsetsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ListPartitionReassignmentsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ListPartitionReassignmentsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ListTransactionsRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ListTransactionsResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/MetadataRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/MetadataResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/OffsetCommitRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/OffsetCommitResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/OffsetDeleteRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/OffsetDeleteResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/OffsetFetchRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/OffsetFetchResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/OffsetForLeaderEpochRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/OffsetForLeaderEpochResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ProduceRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ProduceResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/RequestHeader.json
+${PYSITELIB}/kafka/protocol/schemas/resources/ResponseHeader.json
+${PYSITELIB}/kafka/protocol/schemas/resources/SaslAuthenticateRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/SaslAuthenticateResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/SaslHandshakeRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/SaslHandshakeResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/SyncGroupRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/SyncGroupResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/TxnOffsetCommitRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/TxnOffsetCommitResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/UpdateFeaturesRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/UpdateFeaturesResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/WriteTxnMarkersRequest.json
+${PYSITELIB}/kafka/protocol/schemas/resources/WriteTxnMarkersResponse.json
+${PYSITELIB}/kafka/protocol/schemas/resources/__init__.py
+${PYSITELIB}/kafka/protocol/schemas/resources/__init__.pyc
+${PYSITELIB}/kafka/protocol/schemas/resources/__init__.pyo
 ${PYSITELIB}/kafka/record/__init__.py
 ${PYSITELIB}/kafka/record/__init__.pyc
 ${PYSITELIB}/kafka/record/__init__.pyo
@@ -288,6 +832,15 @@ ${PYSITELIB}/kafka/serializer/__init__.p
 ${PYSITELIB}/kafka/serializer/abstract.py
 ${PYSITELIB}/kafka/serializer/abstract.pyc
 ${PYSITELIB}/kafka/serializer/abstract.pyo
+${PYSITELIB}/kafka/serializer/default.py
+${PYSITELIB}/kafka/serializer/default.pyc
+${PYSITELIB}/kafka/serializer/default.pyo
+${PYSITELIB}/kafka/serializer/json.py
+${PYSITELIB}/kafka/serializer/json.pyc
+${PYSITELIB}/kafka/serializer/json.pyo
+${PYSITELIB}/kafka/serializer/wrapper.py
+${PYSITELIB}/kafka/serializer/wrapper.pyc
+${PYSITELIB}/kafka/serializer/wrapper.pyo
 ${PYSITELIB}/kafka/structs.py
 ${PYSITELIB}/kafka/structs.pyc
 ${PYSITELIB}/kafka/structs.pyo
@@ -297,18 +850,6 @@ ${PYSITELIB}/kafka/util.pyo
 ${PYSITELIB}/kafka/vendor/__init__.py
 ${PYSITELIB}/kafka/vendor/__init__.pyc
 ${PYSITELIB}/kafka/vendor/__init__.pyo
-${PYSITELIB}/kafka/vendor/enum34.py
-${PYSITELIB}/kafka/vendor/enum34.pyc
-${PYSITELIB}/kafka/vendor/enum34.pyo
-${PYSITELIB}/kafka/vendor/selectors34.py
-${PYSITELIB}/kafka/vendor/selectors34.pyc
-${PYSITELIB}/kafka/vendor/selectors34.pyo
-${PYSITELIB}/kafka/vendor/six.py
-${PYSITELIB}/kafka/vendor/six.pyc
-${PYSITELIB}/kafka/vendor/six.pyo
-${PYSITELIB}/kafka/vendor/socketpair.py
-${PYSITELIB}/kafka/vendor/socketpair.pyc
-${PYSITELIB}/kafka/vendor/socketpair.pyo
 ${PYSITELIB}/kafka/version.py
 ${PYSITELIB}/kafka/version.pyc
 ${PYSITELIB}/kafka/version.pyo

Index: pkgsrc/devel/py-kafka-python/distinfo
diff -u pkgsrc/devel/py-kafka-python/distinfo:1.4 pkgsrc/devel/py-kafka-python/distinfo:1.5
--- pkgsrc/devel/py-kafka-python/distinfo:1.4   Tue Oct 26 10:18:37 2021
+++ pkgsrc/devel/py-kafka-python/distinfo       Wed Jun 24 08:49:54 2026
@@ -1,5 +1,5 @@
-$NetBSD: distinfo,v 1.4 2021/10/26 10:18:37 nia Exp $
+$NetBSD: distinfo,v 1.5 2026/06/24 08:49:54 adam Exp $
 
-BLAKE2s (kafka-python-1.4.4.tar.gz) = 8cd2cf61f6798ba072f1d9664c1467d770d6fa07a5f2b6744088ad3407120e66
-SHA512 (kafka-python-1.4.4.tar.gz) = 856116c01a162411542e603de7202f9ff5e3987aeee77691366771c5cca7f836bdab66b921e97100159f38e1a17c4e94cb772376f4809bf8bea4203b2b00f788
-Size (kafka-python-1.4.4.tar.gz) = 279069 bytes
+BLAKE2s (kafka_python-3.0.4.tar.gz) = 3f5a2a9d012575f438086d67845df28715bd6dbe99c4eec1969df4fa87353c02
+SHA512 (kafka_python-3.0.4.tar.gz) = 3d4a5ac76f76818b379ba43bbef58bb558c0a82c0bc45fb19383a7004aeec6d4107467d151c4895caf29dbdb9f28fd66460c16532b5edd5bfe823a997da2c7fd
+Size (kafka_python-3.0.4.tar.gz) = 506315 bytes

Added files:

Index: pkgsrc/devel/py-kafka-python/ALTERNATIVES
diff -u /dev/null pkgsrc/devel/py-kafka-python/ALTERNATIVES:1.1
--- /dev/null   Wed Jun 24 08:49:54 2026
+++ pkgsrc/devel/py-kafka-python/ALTERNATIVES   Wed Jun 24 08:49:54 2026
@@ -0,0 +1 @@
+bin/kafka-python @PREFIX@/bin/kafka-python-@PYVERSSUFFIX@
Home | Main Index | Thread Index | Old Index