commits

Python client for Apache Kafka

SHA	Message	Author	Date
512d0a0b	Fetcher: Add missing argument in debug log (#2665) Co-authored-by: Alexandre Feblot <a**t@f**m>	Alexandre Feblot <a**t@gm> Committed by: GitHub <ny@g**m>	4 months ago
20e2d52f	KIP-654: Abort transaction with pending data with TransactionAbortedError (#2...	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
ee5436f0	KafkaProducer: Handle UnknownProducerIdError (#2663)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
92276744	KIP-467: Augment ProduceResponse error messaging for specific culprit records...	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
0a871300	Update changelog for 2.2 patch releases + bump version for 2.3.x releases	Dana Powers <d**s@g**m>	4 months ago
e91b036a	Fix KafkaProducer broken method names (#2660)	llk89 <w**r@om> Committed by: GitHub <ny@g**m>	4 months ago
2297fa15	Fix spelling mistake in KafkaConsumer docs (#2659)	Xeus-CC <x**x@gm> Committed by: GitHub <ny@g**m>	4 months ago
2abf2cd6	KIP-207: Add ListOffsetsRequest v5 / handle OffsetNotAvailableError (#2657)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
93bcddeb	KIP-430: Return Authorized Operations in Describe Responses (#2656)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
8fb3f961	python2 fixups (#2655)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
223c3207	Remove old/unused kafka.protocol.pickle (#2653)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
8c6c9da8	Switch protocol code to getattr/setattr from __dict__ (#2654)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
c8d6cdac	cli fixups: producer stdin/eof support; consumer unused e var	Dana Powers <d**s@g**m>	4 months ago
46319a36	cli fixups: producer py2 compat; consumer no stacktrace on KafkaError	Dana Powers <d**s@g**m>	4 months ago
8d75d9a0	KIP-345 Consumer group static membership (#2625)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
c95dad94	Fix coordinator lock contention during close() (#2652)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
7b565ae5	Drop unused imports (#2651)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
6f6a6968	python -m cli interfaces for kafka.admin, kafka.consumer, kafka.producer (#2650)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
179c8ed9	Add send_request() and send_requests() to KafkaAdminClient (#2649)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	4 months ago
f6eb0b40	Patch Release 2.2.13	Dana Powers <d**s@g**m>	4 months ago
0735a7c0	Fixup import style in example.py	Dana Powers <d**s@g**m>	5 months ago
cf1cd104	Use client.await_ready() to simplify blocking wait and add timeout to admin c...	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	5 months ago
e4e6fcf3	update README kafka version badge to include 4.0	Dana Powers <d**s@g**m>	5 months ago
e22e41e2	Patch Release 2.2.12	Dana Powers <d**s@g**m>	5 months ago
02453523	Fix construction of final GSSAPI authentication message (#2647)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	5 months ago
5d83941c	Avoid RuntimeError on mutated _completed_fetches deque in consumer fetcher (#...	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	5 months ago
5c7cd2f2	Throw exception on invalid bucket type (#2642) Signed-off-by: Emmanuel Ferdman <e**n@g**m>	Emmanuel Ferdman <e**n@gm> Committed by: GitHub <ny@g**m>	5 months ago
3542e01a	Patch Release 2.2.11	Dana Powers <d**s@g**m>	5 months ago
e93ab64c	Do not ignore metadata response for single topic with error (#2640)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	5 months ago
9f7384c2	Fix decoding bug in AWS_MSK_IAM mechanism (#2639)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	5 months ago
e6abbbf2	Add synchronized decorator; add lock to subscription state (#2636)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	5 months ago
5957c1ba	Update build links in documentation (#2634)	Raphael Boidol <b**r@um> Committed by: GitHub <ny@g**m>	5 months ago
65834607	Patch Release 2.2.10	Dana Powers <d**s@g**m>	5 months ago
7fceb1bd	Pass host as kwarg to get_sasl_mechanism	Dana Powers <d**s@g**m>	5 months ago
e2b66930	Set the current host in the SASL configs (#2633) Co-authored-by: Sebastian.Meinhardt <S**t@v**m>	SeppMe <4**e@um> Committed by: GitHub <ny@g**m>	5 months ago
7b7f3afc	Fix sasl gssapi plugin: do not rely on client_ctx.complete in auth_bytes() (#...	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	5 months ago
48dd5964	Patch Release 2.2.9	Dana Powers <d**s@g**m>	5 months ago
bd217132	More / updated debug logging for coordinator / consumer (#2630)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	5 months ago
3463f595	Do not reset fetch positions if offset commit fetch times out (#2629)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	5 months ago
bcbd1b71	Patch Release 2.2.8	Dana Powers <d**s@g**m>	6 months ago
95c2f3af	Dont mark coordinator dead on ThrottlingQuotaExceededError	Dana Powers <d**s@g**m>	6 months ago
62a7d80d	Fix timeout seconds error message in KafkaProducer (#2627)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
452e354c	Log all SyncGroupResponse errors as info+	Dana Powers <d**s@g**m>	6 months ago
5de666a1	More coordinator / heartbeat logging (#2621)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
8f77cc8b	Update offset commit error handling; use RebalanceInProgressError if applicab...	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
2f95590f	Wait for next heartbeat in thread loop; check for connected coordinator (#2622)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
8a424e91	Acquire client lock in heartbeat thread before sending requests (#2620)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
00a5e6c6	Patch Release 2.2.7	Dana Powers <d**s@g**m>	6 months ago
71c10f41	Minor Heartbeat updates: catch more exceptions / log configuration / raise Ka...	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
be22ee5a	Patch Release 2.2.6	Dana Powers <d**s@g**m>	6 months ago
32a92852	Only disable heartbeat thread once at beginning of join-group (#2617)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
bf77e9a0	Patch Release 2.2.5	Dana Powers <d**s@g**m>	6 months ago
590ef937	Fix producer busy loop with no pending batches (#2616)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
7536bcbf	Fixup py27 fetcher test failure	Dana Powers <d**s@g**m>	6 months ago
fef828f7	Bump version for development	Dana Powers <d**s@g**m>	6 months ago
d8c9bb12	Patch Release 2.2.4	Dana Powers <d**s@g**m>	6 months ago
d9c2009d	Do not reset_generation after RebalanceInProgressError; improve CommitFailed ...	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
2f282ebc	Fix KafkaConsumer.poll() with zero timeout (#2613)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
41003190	Fix Fetch._reset_offsets_async() KeyError when fetching from multiple nodes (...	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
827832ab	Update changes w/ 2.1.6 backport release	Dana Powers <d**s@g**m>	6 months ago
2767d14b	Patch Release 2.2.3	Dana Powers <d**s@g**m>	6 months ago
cef0ea69	Ignore leading SECURITY_PROTOCOL:// in bootstrap_servers (#2608)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
b6036f23	Only create fetch requests for ready nodes (#2607)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
26fbd2ee	Bump version for development	Dana Powers <d**s@g**m>	6 months ago
3d31c14b	Patch Release 2.2.2	Dana Powers <d**s@g**m>	6 months ago
998efc25	Fix lint errors	Dana Powers <d**s@g**m>	6 months ago
cb2868fa	Bump version for development	Dana Powers <d**s@g**m>	6 months ago
8c397330	Patch Release 2.2.1	Dana Powers <d**s@g**m>	6 months ago
842f398f	Always try ApiVersionsRequest v0, even on broker disconnect (#2603)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
c35c1614	Fix SubscriptionState AttributeError in KafkaConsumer (#2599)	cheterchao <4**7@um> Committed by: GitHub <ny@g**m>	6 months ago
284c8a7c	Add transactional examples to docs	Dana Powers <d**s@g**m>	6 months ago
0f481e07	Bump version for development	Dana Powers <d**s@g**m>	6 months ago
603e10eb	Release 2.2.0	Dana Powers <d**s@g**m>	6 months ago
fb046266	KIP-394: handle MEMBER_ID_REQUIRED error w/ second join group request (#2598)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
b1dae2ef	RecordAccumulator: Use helper method to get/set _tp_locks; get dq with lock i...	Dana Powers <d**s@g**m>	6 months ago
707913fb	Expand KafkaProducer docstring w/ idempotent and transactional notes	Dana Powers <d**s@g**m>	6 months ago
4f87a877	Default retries -> infinite	Dana Powers <d**s@g**m>	6 months ago
3b766e2c	KIP-91: KafkaProducer delivery_timeout_ms	Dana Powers <d**s@g**m>	6 months ago
1f635141	MemoryRecords iterator; MemoryRecordsBuilder records() helper	Dana Powers <d**s@g**m>	6 months ago
3ee0419e	DefaultRecordsBuilder.size_in_bytes classmethod	Dana Powers <d**s@g**m>	6 months ago
17ba216b	from __future__ import division for produce batch time calcs	Dana Powers <d**s@g**m>	6 months ago
186d480f	KAFKA-5429 - Ignore produce response if batch was previously aborted	Dana Powers <d**s@g**m>	6 months ago
92037ce0	Do not include log_start_offset in producer RecordMetadata	Dana Powers <d**s@g**m>	6 months ago
9188385c	Fix ElectionNotNeededError handling in admin client	Dana Powers <d**s@g**m>	6 months ago
be9dd7c9	KAFKA-6397: Consumer should not block setting positions of unavailable partit...	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	6 months ago
39aa4218	fixup exception message	Dana Powers <d**s@g**m>	6 months ago
1b53598d	Drop unused KafkaClient import from test_fetcher	Dana Powers <d**s@g**m>	7 months ago
9300bcbe	KAFKA-5078 - defer fetch record exception if iterator has already moved acros...	Dana Powers <d**s@g**m>	7 months ago
2513d55b	KAFKA-5075 - Defer consumer fetcher exception if fetch position has already i...	Dana Powers <d**s@g**m>	7 months ago
d1666680	KAFKA-4937: Batch offset fetches in the Consumer	Dana Powers <d**s@g**m>	7 months ago
e92defe7	Fix client.wakeup() race from producer/sender close	Dana Powers <d**s@g**m>	7 months ago
a2f8c581	Avoid self refcount in log messages; test thread close on all pythons	Dana Powers <d**s@g**m>	7 months ago
2f262b9f	KAFKA-4547: Avoid resetting paused partitions to committed offsets	Dana Powers <d**s@g**m>	7 months ago
99c08e66	Prefix producer logs w/ client id and transactional id (#2591)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	7 months ago
c5cbe840	fixup reset_producer_id is_transactional() check	Dana Powers <d**s@g**m>	7 months ago
a87f9220	KIP-98: Add offsets support to transactional KafkaProducer (#2590)	Dana Powers <d**s@gm> Committed by: GitHub <ny@g**m>	7 months ago
315f9d84	Fixup retry/sleep after successful init producer id in idempotent producer	Dana Powers <d**s@g**m>	7 months ago
369478aa	Remove old/unused errors; reorder; KafkaTimeout -> retriable	Dana Powers <d**s@g**m>	7 months ago
e2c3b80f	Resolve datetime deprecation warnings (#2589)	Emmanuel Ferdman <e**n@gm> Committed by: GitHub <ny@g**m>	7 months ago
7a0e9f61	py2 test fixups	Dana Powers <d**s@g**m>	7 months ago

← Back to repository

ecosyste.ms

Data

Tools

Indexes

Applications

Experiments

Commits

GitHub / dpkp/kafka-python / commits