summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Vendor enum34Jeff Widman2018-10-221-0/+841
* Vendor `six` consistentlyJeff Widman2018-10-222-4/+4
* Update remote urls: snappy, https, etcJeff Widman2018-10-223-5/+5
* Bump vendored `six` to `1.11.0`Jeff Widman2018-10-221-16/+42
* Support produce with Kafka record headersHeikki Nousiainen2018-09-273-17/+27
* Expose record headers in ConsumerRecordsHeikki Nousiainen2018-09-271-3/+5
* Expose ConsumerRebalanceListener in allBen Harack2018-09-271-1/+1
* Remove ConsumerTimeoutJonathan Emord2018-09-271-4/+0
* Clear the metrics dictionary on close. (#1569)Kishore Nallan2018-08-311-0/+2
* Return future from commit_offsets_async (#1560)Mike Lang2018-08-311-1/+6
* add kerberos domain name config for gssapi sasl mechanism handshake (#1542)the-sea2018-08-314-4/+17
* add support for smaller topic metadata fetch during bootstrap (#1541)Ning Xie2018-08-313-6/+14
* Document connections_max_idle_msJeff Widman2018-06-263-0/+15
* Don't use `kafka.common` internally1.3.5Jeff Widman2018-06-0510-23/+18
* Bump version for developmentDana Powers2018-05-261-1/+1
* Release 1.4.31.4.3Dana Powers2018-05-261-1/+1
* Retain but deprecate kafka.errors.ConnectionError for compatibilityDana Powers2018-05-261-0/+4
* Improve connection handling when bootstrap list is invalid (#1507)Dana Powers2018-05-261-6/+3
* Ignore MetadataResponses with empty broker list (#1506)Dana Powers2018-05-262-1/+6
* Document methods that return NoneJeff Widman2018-05-231-0/+3
* Stop shadowing `ConnectionError`Jeff Widman2018-05-235-25/+24
* Stop using deprecated log.warn()Jeff Widman2018-05-101-3/+3
* Minor doc capitalization cleanupJeff Widman2018-04-241-15/+15
* Force lz4 to disable Kafka-unsupported block linking when encoding (#1476)Michael P. Nitowski2018-04-181-1/+13
* Added AlterConfigs and DescribeConfigs apis (#1472)Stephen SORRIAUX2018-04-181-1/+96
* Add codec validators to record parser and builder for all formats (#1447)Taras2018-04-182-6/+34
* Fix MemoryRecord bugs re error handling and add test coverage (#1448)Taras2018-04-183-7/+7
* Always acquire client lock before coordinator lock to avoid deadlocks (#1464)Dana Powers2018-04-181-59/+64
* Improve BrokerConnection initialization (#1475)Rômulo Rosa Furtado2018-04-151-1/+1
* Fix CreatePartitionsRequest_v0 (#1469)Stephen SORRIAUX2018-04-051-1/+1
* Heartbeat thread start / closeDana Powers2018-03-231-2/+4
* Change levels for some heartbeat thread loggingDana Powers2018-03-231-3/+3
* Fix KafkaConsumer docstring for request_timeout_ms default (#1459)Dana Powers2018-03-233-5/+5
* Change SimpleProducer to use async_send (async is reserved in py37) (#1454)Dana Powers2018-03-233-17/+25
* Check for immediate failure when looking up coordinator in heartbeat thread (...Dana Powers2018-03-231-1/+5
* Bump version for developmentDana Powers2018-03-101-1/+1
* Patch Release 1.4.21.4.2Dana Powers2018-03-101-1/+1
* KAFKA-5512; Awake the heartbeat thread when timetoNextHeartbeat is equal to 0...Dana Powers2018-03-101-0/+4
* Remove old CommitFailed error message from coordinator (#1436)Dana Powers2018-03-101-11/+1
* Validate that serializers generate bytes-like (or None) data (#1420)Dana Powers2018-03-101-2/+3
* Do not validate api_version against known versions (#1434)Dana Powers2018-03-103-20/+3
* Connect with sockaddrs to support non-zero ipv6 scope ids (#1433)Dana Powers2018-03-091-13/+10
* Re-enable logging during broker version check (#1430)Dana Powers2018-03-091-12/+1
* Connection logging cleanups (#1432)Dana Powers2018-03-091-4/+5
* Add BrokerConnection.connect_blocking() (#1411)Dana Powers2018-03-093-33/+49
* Short-circuit BrokerConnection.close() if already disconnected (#1424)Dana Powers2018-03-091-3/+6
* Only increase reconnect backoff if all addrinfos have been tried (#1423)Dana Powers2018-03-091-1/+4
* Support alternative lz4framed (#1395)everpcpc2018-03-091-0/+11
* Close leaked selector in version check (#1425)Dana Powers2018-03-091-0/+1
* Make BrokerConnection .host / .port / .afi immutable, use _sock_* attributes ...Dana Powers2018-03-091-15/+25
View Lorry Controller Status