summaryrefslogtreecommitdiff
path: root/kafka/consumer/group.py
Commit message (Expand)AuthorAgeFilesLines
* StopIteration when consumer closedissue-1219-closed-consumerDana Powers2019-12-291-0/+2
* Raise AssertionError if consumer closed in poll()Dana Powers2019-12-291-0/+1
* Improve docs for reconnect_backoff_max_ms (#1976)Dana Powers2019-12-281-5/+6
* Remove SimpleClient, Producer, Consumer, Unittest (#1196)Jeff Widman2019-10-111-25/+0
* Improve/refactor bootstrap_connectedDana Powers2019-09-301-3/+1
* Added a function to determine if bootstrap is successfully connected (#1876)PandllCom2019-09-301-0/+6
* Send socket data via non-blocking IO with send buffer (#1912)Dana Powers2019-09-291-2/+6
* Wrap consumer.poll() for KafkaConsumer iteration (#1902)Dana Powers2019-09-281-6/+63
* Reduce internal client poll timeout for consumer iterator interface (#1824)Dana Powers2019-08-161-3/+1
* Update link to upstream Kafka docsJeff Widman2019-07-111-1/+1
* Update docs for api_version_auto_timeout_ms (#1812)Jeff Widman2019-05-241-1/+1
* Fix typo in _fetch_all_topic_metadata function (#1809)Brian Sang2019-05-231-1/+1
* Make partitions_for_topic a read-through cache (#1781)Brian Sang2019-05-221-8/+25
* Update link to kafka docsJeff Widman2019-05-171-1/+1
* Update sasl configuration docstringsDana Powers2019-03-231-5/+5
* Support SASL OAuthBearer Authentication (#1750)Phong Pham2019-03-221-1/+4
* Allow configuration of SSL Ciphers (#1755)Dana Powers2019-03-211-0/+6
* Error if connections_max_idle_ms not larger than request_timeout_ms (#1688)Jeff Widman2019-03-141-3/+7
* Do network connections and writes in KafkaClient.poll() (#1729)Dana Powers2019-03-081-12/+1
* Remove unused `skip_double_compressed_messages`Jeff Widman2019-01-131-8/+0
* #1681 add copy() in metrics() to avoid thread safety issues (#1682)Tosi Émeric2018-12-271-2/+2
* Be explicit with tuples for %s formattingJeff Widman2018-11-181-1/+1
* add kerberos domain name config for gssapi sasl mechanism handshake (#1542)the-sea2018-08-311-1/+4
* Document connections_max_idle_msJeff Widman2018-06-261-0/+5
* Fix KafkaConsumer docstring for request_timeout_ms default (#1459)Dana Powers2018-03-231-1/+1
* Do not validate api_version against known versions (#1434)Dana Powers2018-03-101-2/+1
* Avoid tight poll loop in consumer when brokers are down (#1415)Dana Powers2018-03-081-1/+1
* Validate max_records in KafkaConsumer.poll (#1398)Dana Powers2018-02-271-0/+2
* Correctly respect timeouts in consumer poll interface (#1384)Braedon Vickers2018-02-211-1/+1
* KAFKA-3949: Avoid race condition when subscription changes during rebalance (...Dana Powers2018-02-021-0/+10
* Read all available socket bytes (#1332)Dana Powers2018-01-101-0/+2
* KAFKA-3888 Use background thread to process consumer heartbeats (#1266)Dana Powers2017-12-211-46/+56
* Use correct casing for MBJeff Widman2017-11-151-1/+1
* Fix overriding sasl_kerberos_service_name in KafkaConsumer / KafkaProducer (#...Nathanael Smith2017-10-171-0/+3
* Fix docstringJeff Widman2017-10-161-3/+4
* KAFKA-4034: Avoid unnecessary consumer coordinator lookup (#1254)Dana Powers2017-10-111-10/+19
* Expand metrics docs (#1243)Jeff Widman2017-10-081-4/+11
* remove beginning/end offsets request version limitLiao Jiayi2017-09-041-8/+0
* Remove a few unused imports (#1188)James Lamb2017-08-291-1/+0
* Drop unused sleep kwarg to poll (#1177)Dana Powers2017-08-151-2/+4
* Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman revie...Taras Voinarovskiy2017-08-071-11/+76
* Changed retrieve_offsets to allow fetching multiple offsets at onceTaras Voinarovskiy2017-08-071-1/+3
* Added basic support for offsets_for_times API. Still needs to group by nodes ...Taras Voinarovskiy2017-08-071-1/+41
* KIP-144: Exponential backoff for broker reconnections (#1124)Dana Powers2017-06-191-0/+9
* Describe consumer thread-safetyLinus Wallgren2017-06-161-0/+2
* Follow-up to #1068: remove not-implemented commentsDana Powers2017-04-101-1/+1
* Additional docstrings for autocommit close optionDana Powers2017-03-131-1/+7
* Optionally skip auto-commit during consumer.close (#1031)Dana Powers2017-03-131-2/+2
* Return copy of consumer subscription set (#1029)Dana Powers2017-03-131-1/+1
* A few Sphinx documentation updates (#1019)Jeff Widman2017-03-081-3/+3
View Lorry Controller Status