summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Collapse)AuthorAgeFilesLines
* Don't use `kafka.common` internally1.3.5Jeff Widman2018-06-0510-23/+18
| | | | This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.
* 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
| | | | * only perform single dns lookup for connect_blocking() * fix blocking timeout in check_version()
* Ignore MetadataResponses with empty broker list (#1506)Dana Powers2018-05-262-1/+6
|
* 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-235-25/+24
| | | | | | | | | | 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
|
* 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
| | | | (#1457)
* 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 ↵Dana Powers2018-03-101-0/+4
| | | | 0 (#1439)
* 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
| | | | 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-081-2/+9
|
* 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-261-8/+9
|
* Fix byte size estimation with kafka producer (#1393)Blake Embrey2018-02-241-1/+1
|
* Check timeout type in KafkaClient constructorAndre Araujo2018-02-211-0/+2
| | | | | | | | | | If a future was passed as the only positional parameter it would be assigned to the "timeout_ms" parameter erroneously. This mistake would not raise any exception but would lead to odd behaviour later, what could make it extremely difficult to troubleshoot. Adding a type check ensures that an exception is raise earlier to notify the user about the problem.
* Update string representation of SimpleClientAndre Araujo2018-02-211-1/+1
|
* Use hardware accelerated CRC32C function if available (#1389)Taras Voinarovskyi2018-02-211-3/+11
| | | | | | * Use hardware accelerated CRC32C function if available * Add doc notice of optional `crc32c` package
* Correctly respect timeouts in consumer poll interface (#1384)Braedon Vickers2018-02-211-1/+1
|
* Fix response schemaAlex Eftimie2018-02-201-1/+2
|
* Add Admin CreatePartitions API callAlex Eftimie2018-02-202-1/+32
|
View Lorry Controller Status