./devel/py-kafka-python, Pure Python client for Apache Kafka

[ CVSweb ] [ Homepage ] [ RSS ] [ Required by ] [ Add to tracker ]

Branch: CURRENT, Version: 1.4.4nb1, Package name: py310-kafka-python-1.4.4nb1, Maintainer: minskim

Python client for the Apache Kafka distributed stream processing
system. kafka-python is designed to function much like the official
java client, with a sprinkling of pythonic interfaces (e.g., consumer
iterators).


Required to run:
[devel/py-setuptools] [lang/python27]

Required to build:
[pkgtools/cwrappers]

Master sites:

Filesize: 272.528 KB

Version history: (Expand)

CVS history: (Expand)


   2022-01-04 21:55:40 by Thomas Klausner | Files touched by this commit (1595) 
Log message:
*: bump PKGREVISION for egg.mk users

They now have a tool dependency on py-setuptools instead of a DEPENDS
   2021-10-26 12:20:11 by Nia Alarie | Files touched by this commit (3016) 
Log message:
archivers: Replace RMD160 checksums with BLAKE2s checksums

All checksums have been double-checked against existing RMD160 and
SHA512 hashes

Could not be committed due to merge conflict:
devel/py-traitlets/distinfo

The following distfiles were unfetchable (note: some may be only fetched
conditionally):

./devel/pvs/distinfo pvs-3.2-solaris.tgz
./devel/eclipse/distinfo eclipse-sourceBuild-srcIncluded-3.0.1.zip
   2021-10-07 15:44:44 by Nia Alarie | Files touched by this commit (3017) 
Log message:
devel: Remove SHA1 hashes for distfiles
   2018-12-04 13:54:01 by Adam Ciarcinski | Files touched by this commit (3) | Package updated
Log message:
py-kafka-python: updated to 1.4.4

1.4.4:

Bugfixes
* (Attempt to) Fix deadlock between consumer and heartbeat
* Fix Metrics dict memory leak

Client
* Support Kafka record headers
* Set socket timeout for the write-side of wake socketpair
* Add kerberos domain name config for gssapi sasl mechanism handshake
* Support smaller topic metadata fetch during bootstrap
* Use TypeError for invalid timeout type
* Break poll if closed

Admin Client
* Add KafkaAdminClient class
* Fix list_consumer_groups() to query all brokers
* Stop using broker-errors for client-side problems
* Fix send to controller
* Add group coordinator lookup
* Fix describe_groups
* Add list_consumer_group_offsets()
* Remove support for api versions as strings from KafkaAdminClient
* Set a clear default value for validate_only/include_synonyms
* Bugfix: Always set this_groups_coordinator_id

Consumer
* Fix linter warning on import of ConsumerRebalanceListener
* Remove ConsumerTimeout
* Return future from commit_offsets_async()

Core / Protocol
* Add protocol structs for {Describe,Create,Delete} Acls
* Pre-compile pack/unpack function calls
* Don't use kafka.common internally
* Be explicit with tuples for %s formatting

Documentation
* Document connections_max_idle_ms
* Fix sphinx url
* Update remote urls: snappy, https, etc
* Minor cleanup of testing doc
* Various docstring / pep8 / code hygiene cleanups

Test Infrastructure
* Stop pinning pylint
* (partial) Migrate from Unittest to pytest
* Minor aesthetic cleanup of partitioner tests
* Cleanup fixture imports
* Fix typo in test file name
* Remove unused ivy_root variable
* Add test fixtures for kafka versions 1.0.2 -> 2.0.1
* Bump travis test for 1.x brokers to 1.1.1

Logging / Error Messages
* raising logging level on messages signalling data loss
* Stop using deprecated log.warn()
* Fix typo in logging message

Compatibility
* Vendor enum34
* Bump vendored six to 1.11.0
* Vendor six consistently
* Prevent pylint import errors on six.moves
   2018-07-10 03:16:37 by Min Sik Kim | Files touched by this commit (4) 
Log message:
devel/py-kafka-python: Import version 1.4.3

Python client for the Apache Kafka distributed stream processing
system. kafka-python is designed to function much like the official
java client, with a sprinkling of pythonic interfaces (e.g., consumer
iterators).

This package replaces devel/py-kafka.