Files

 master

/

kafka

/

Copy path

Directory actions

More options

Directory actions

More options

Latest commit

dpkp

Add protocol defs for AddPartitionsToTxn, EndTxn, and AddOffsetsToTxn

Apr 8, 2025

3962d67 · Apr 8, 2025

History

History

/

kafka

/

Top

Folders and files

Name		Name	Last commit message	Last commit date
parent directory ..
admin		admin	Rename Coordinator errors to generic not group (#2585)	Apr 7, 2025
benchmarks		benchmarks	Move benchmark scripts to kafka.benchmarks module (#2584)	Apr 4, 2025
consumer		consumer	Rename CorruptRecordException -> CorruptRecordError	Apr 8, 2025
coordinator		coordinator	Cluster.add_group_coordinator -> add_coordinator + support txn type	Apr 8, 2025
metrics		metrics	Use __slots__ for metrics (#2583)	Apr 4, 2025
partitioner		partitioner	Remove SimpleClient, Producer, Consumer, Unittest (#1196)	Oct 11, 2019
producer		producer	Dont raise KeyError on incomplete.remove(batch)	Apr 8, 2025
protocol		protocol	Add protocol defs for AddPartitionsToTxn, EndTxn, and AddOffsetsToTxn	Apr 8, 2025
record		record	Rename CorruptRecordException -> CorruptRecordError	Apr 8, 2025
sasl		sasl	Send final error byte x01 on Sasl OAuth failure (#2572)	Mar 27, 2025
serializer		serializer	use absolute imports everywhere (#1362)	Feb 6, 2018
vendor		vendor	Update socketpair w/ CVE-2024-3219 fix (#2468)	Feb 12, 2025
__init__.py		__init__.py	Add .readthedocs.yaml; update copyright date (#2474)	Feb 12, 2025
client_async.py		client_async.py	KIP-98: Add idempotent producer support (#2569)	Apr 6, 2025
cluster.py		cluster.py	Cluster.add_group_coordinator -> add_coordinator + support txn type	Apr 8, 2025
codec.py		codec.py	Do not validate snappy xerial header version and compat fields (#2483)	Feb 17, 2025
conn.py		conn.py	Use SaslAuthenticationFailedError in kafka.conn connection failure	Apr 8, 2025
errors.py		errors.py	Use SaslAuthenticationFailedError in kafka.conn connection failure	Apr 8, 2025
future.py		future.py	Add lock synchronization to Future success/failure (#2549)	Mar 16, 2025
socks5_wrapper.py		socks5_wrapper.py	Support connections through SOCKS5 proxies	Mar 14, 2025
structs.py		structs.py	Add baseline leader_epoch support for ListOffsets v4 / FetchRequest v…	Mar 5, 2025
util.py		util.py	Move ensure_valid_topic_name to kafka.util; use in client and producer (	Mar 24, 2025
version.py		version.py	Bump version for development	Apr 4, 2025
View all files