summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
* 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.
* 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-214-5/+28
| | | | | | * 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