summaryrefslogtreecommitdiff
Commit message (Expand)AuthorAgeFilesLines
...
* Added a function to determine if bootstrap is successfully connected (#1876)PandllCom2019-09-302-7/+20
* Issue #1780 - Consumer hang indefinitely in fetcher._retrieve_offsets() due t...Commander Dishwasher2019-09-303-12/+26
* Change coordinator lock acquisition order (#1821)Dana Powers2019-09-292-43/+39
* Send socket data via non-blocking IO with send buffer (#1912)Dana Powers2019-09-294-13/+108
* Do not use wakeup when sending fetch requests from consumer (#1911)Dana Powers2019-09-292-2/+2
* Rely on socket selector to detect completed connection attempts (#1909)Dana Powers2019-09-285-11/+15
* Wrap consumer.poll() for KafkaConsumer iteration (#1902)Dana Powers2019-09-283-11/+74
* Skip admin integration tests -- travis fixture issuesDana Powers2019-09-281-4/+7
* Update kafka.properties for ACL tests (0.11+ only)Dana Powers2019-09-287-18/+3
* Fix Admin Client api version checking; only test ACL integration on 0.11+Dana Powers2019-09-282-9/+18
* Fixup test_admin_integration test fixturesDana Powers2019-09-281-5/+14
* Add ACL api to KafkaAdminClient (#1833)Ulrik Johansson2019-09-2822-9/+674
* kafka-python: Fixed crc32c avilability on non-intel architectures. (#1904)ossdev072019-09-252-1/+2
* Improve connection lock handling; always use context manager (#1895)Dana Powers2019-09-031-126/+151
* Convert remaining `KafkaConsumer` tests to `pytest` (#1886)Jeff Widman2019-08-224-256/+284
* Bump integration tests to 0.10.2.2 and 0.11.0.3 (#1890)Jeff Widman2019-08-228-4/+380
* Cleanup handling of KAFKA_VERSION env var in tests (#1887)Jeff Widman2019-08-2210-142/+65
* Minor test cleanup (#1885)Jeff Widman2019-08-218-11/+25
* Reduce internal client poll timeout for consumer iterator interface (#1824)Dana Powers2019-08-161-3/+1
* Update conn.pyCameron Boulton2019-08-161-0/+3
* tests: Use socket.SOCK_STREAM in assertionsIvan A. Melnikov2019-08-151-4/+4
* Break FindCoordinator into request/response methodsJeff Widman2019-07-311-32/+48
* Fix minor typo (#1865)Carson Ip2019-07-142-2/+2
* Update link to upstream Kafka docsJeff Widman2019-07-111-1/+1
* Add the `sasl_kerberos_domain_name` arg to `KafkaAdminClient`Jeff Widman2019-06-281-0/+3
* Update KafkaAdminClient DocsRob Cardy2019-06-211-1/+2
* Allow the coordinator to auto-commit for all api_version.Jay Chan2019-06-201-1/+1
* Break consumer operations into request / response methods (#1845)Jeff Widman2019-06-191-94/+155
* Use dedicated connection for group coordinator (#1822)Dana Powers2019-06-192-25/+17
* Sanity test for consumer.topics() and consumer.partitions_for_topic()Brian Sang2019-06-041-0/+9
* Delay converting to secondsJeff Widman2019-05-301-2/+2
* Reduce client poll timeout when no ifrsDana Powers2019-05-292-0/+15
* Catch TimeoutError in BrokerConnection send/recv (#1820)Dana Powers2019-05-291-6/+7
* Remove unused/weird comment line (#1813)Jeff Widman2019-05-281-1/+0
* Update docs for api_version_auto_timeout_ms (#1812)Jeff Widman2019-05-244-7/+29
* 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
* Remove unused imports (#1808)Jeff Widman2019-05-222-7/+3
* Use futures to parallelize calls to _send_request_to_node() (#1807)Lou-Cipher2019-05-211-34/+75
* Update link to kafka docsJeff Widman2019-05-171-1/+1
* A little python cleanup (#1805)Jeff Widman2019-05-171-4/+2
* Bump version for development of next releaseDana Powers2019-04-031-1/+1
* Release 1.4.61.4.6Dana Powers2019-04-023-1/+91
* Do not call state_change_callback with lock (#1775)Dana Powers2019-04-023-31/+40
* Additional BrokerConnection locks to synchronize protocol/IFR state (#1768)Dana Powers2019-04-021-61/+85
* Return connection state explicitly after close in connect() (#1778)Dana Powers2019-04-021-1/+3
* Reset reconnect backoff on SSL connection (#1777)Dana Powers2019-04-021-0/+1
* Fix possible AttribueError during conn._close_socket (#1776)Dana Powers2019-04-011-1/+1
* Dont treat popped conn.close() as failure in state change callback (#1773)Dana Powers2019-04-012-5/+13
* Avoid race condition on client._conns in send() (#1772)Dana Powers2019-03-311-2/+3