Revisions of python-kafka-python
buildservice-autocommit
accepted
request 482873
from
Jan Matejek (matejcik)
(revision 9)
baserev update by copy to link target
Jan Matejek (matejcik)
accepted
request 482820
from
Thomas Bechtold (tbechtold)
(revision 8)
- update to 1.3.3: Core / Protocol * Derive all api classes from Request / Response base classes (dpkp 1030) * Prefer python-lz4 if available (dpkp 1024) * Fix kwarg handing in kafka.protocol.struct.Struct (dpkp 1025) * Fixed couple of "leaks" when gc is disabled (Mephius 979) * Added `max_bytes` option and FetchRequest_v3 usage. (Drizzt1991 962) * CreateTopicsRequest / Response v1 (dpkp 1012) * Add MetadataRequest_v2 and MetadataResponse_v2 structures for KIP-78 (Drizzt1991 974) * KIP-88 / KAFKA-3853: OffsetFetch v2 structs (jeffwidman 971) * DRY-up the MetadataRequest_v1 struct (jeffwidman 966) * Add JoinGroup v1 structs (jeffwidman 965) * DRY-up the OffsetCommitResponse Structs (jeffwidman 970) * DRY-up the OffsetFetch structs (jeffwidman 964) * time --> timestamp to match Java API (jeffwidman 969) * Add support for offsetRequestV1 messages (jlafaye 951) * Add FetchRequest/Response_v3 structs (jeffwidman 943) * Add CreateTopics / DeleteTopics Structs (jeffwidman 944) Test Infrastructure * Add python3.6 to travis test suite, drop python3.3 (exponea 992) * Update to 0.10.1.1 for integration testing (dpkp 953) * Update vendored berkerpeksag/selectors34 to ff61b82 (Mephius 979) * Remove dead code (jeffwidman 967) * Update pytest fixtures to new yield syntax (jeffwidman 919) Consumer * Avoid re-encoding message for crc check (dpkp 1027) * Optionally skip auto-commit during consumer.close (dpkp 1031) * Return copy of consumer subscription set (dpkp 1029) * Short-circuit group coordinator requests when NodeNotReady (dpkp 995) * Avoid unknown coordinator after client poll (dpkp 1023)
buildservice-autocommit
accepted
request 440324
from
Dirk Mueller (dirkmueller)
(revision 7)
baserev update by copy to link target
Dirk Mueller (dirkmueller)
committed
(revision 6)
- update to 1.3.1: Incompatible Changes * Delete KafkaConnection class (dpkp 769) * Rename partition_assignment -> assignment in MemberMetadata for consistency * Move selectors34 and socketpair to kafka.vendor (dpkp 785) * Change api_version config to tuple; deprecate str with warning (dpkp 761) * Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (dpkp 788)
Dominique Leuenberger (dimstar_suse)
accepted
request 407757
from
Thomas Bechtold (tbechtold)
(revision 5)
initialized devel package after accepting 407757
Thomas Bechtold (tbechtold)
accepted
request 407756
from
Thomas Bechtold (tbechtold)
(revision 4)
- Install LICENSE
Dirk Mueller (dirkmueller)
accepted
request 406288
from
Thomas Bechtold (tbechtold)
(revision 3)
- Use pypi.io for Source url
Thomas Bechtold (tbechtold)
accepted
request 372756
from
Madhu Mohan Nelemane (mmnelemane)
(revision 2)
Upgrading version to kafka-python-1.0.1
Displaying revisions 21 - 29 of 29