summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Release 1.4.31.4.3Dana Powers2018-05-263-1/+85
|
* 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
| | | | * only perform single dns lookup for connect_blocking() * fix blocking timeout in check_version()
* Ignore MetadataResponses with empty broker list (#1506)Dana Powers2018-05-263-1/+28
|
* Document methods that return NoneJeff Widman2018-05-231-0/+3
| | | | | If a valid broker in the cluster has no partitions, it will return None rather than an empty set. Similarly updated a few other methods.
* Stop shadowing `ConnectionError`Jeff Widman2018-05-238-31/+30
| | | | | | | | | | In Python3, `ConnectionError` is a native exception. So rename our custom one to `KafkaConnectionError` to prevent accidentally shadowing the native one. Note that there are still valid uses of `ConnectionError` in this code. They already expect a native Python3 `ConnectionError`, and also already handle the Python2 compatibility issues.
* 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
|
* Skip flakey SimpleProducer testDana Powers2018-04-181-0/+1
|
* 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-189-15/+136
|
* Fix MemoryRecord bugs re error handling and add test coverage (#1448)Taras2018-04-184-8/+75
|
* 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
|
* Adds add_callback/add_errback example to docs (#1441)Berkodev2018-03-291-0/+12
|
* 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-237-34/+42
|
* Check for immediate failure when looking up coordinator in heartbeat thread ↵Dana Powers2018-03-231-1/+5
| | | | (#1457)
* Fix skipped integration tests if KAFKA_VERSION unset (#1453)Dana Powers2018-03-222-0/+9
|
* Bump version for developmentDana Powers2018-03-101-1/+1
|
* Patch Release 1.4.21.4.2Dana Powers2018-03-103-4/+10
|
* KAFKA-5512; Awake the heartbeat thread when timetoNextHeartbeat is equal to ↵Dana Powers2018-03-101-0/+4
| | | | 0 (#1439)
* Add kafka 1.0.1 release to test fixtures (#1437)Dana Powers2018-03-105-2/+190
|
* Remove old CommitFailed error message from coordinator (#1436)Dana Powers2018-03-101-11/+1
|
* Update changelog with unreleased 1.4.2 notesDana Powers2018-03-102-0/+96
|
* 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-092-28/+22
|
* 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-095-36/+55
|
* 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-092-24/+45
| | | | for current lookups (#1422)
* Avoid tight poll loop in consumer when brokers are down (#1415)Dana Powers2018-03-081-1/+1
|
* Fix BrokerConnection.connection_delay() to return milliseconds (#1414)Dana Powers2018-03-082-2/+18
|
* Close KafkaConsumer instances during tests (#1410)Dana Powers2018-03-083-1/+11
|
* Use local copies in Fetcher._fetchable_partitions to avoid mutation errors ↵Dana Powers2018-03-071-3/+6
| | | | (#1400)
* Fix error var name in _unpack (#1403)j2gg0s2018-03-051-1/+1
| | | Change-Id: I6527da4b70ebec9e08fa50aca9eba717b8361f19
* Validate max_records in KafkaConsumer.poll (#1398)Dana Powers2018-02-271-0/+2
|
* Fix KafkaConsumer compacted offset handling (#1397)Dana Powers2018-02-262-10/+28
|
* Fix byte size estimation with kafka producer (#1393)Blake Embrey2018-02-241-1/+1
|
* Fixes racing condition when message is sent to broker before topic logs are ↵Andre Araujo2018-02-211-3/+19
| | | | created
* Introduce new fixtures to prepare for migration to pytest.Andre Araujo2018-02-219-157/+460
| | | | | | | This commits adds new pytest fixtures in prepation for the migration of unittest.TestCases to pytest test cases. The handling of temporary dir creation was also changed so that we can use the pytest tmpdir fixture after the migration.
View Lorry Controller Status