| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Validate that serializers generate bytes-like (or None) datavalidate_serialized_bytes | Dana Powers | 2018-03-08 | 1 | -2/+3 |
| | | |||||
| * | Use local copies in Fetcher._fetchable_partitions to avoid mutation errors ↵ | Dana Powers | 2018-03-07 | 1 | -3/+6 |
| | | | | | (#1400) | ||||
| * | Fix error var name in _unpack (#1403) | j2gg0s | 2018-03-05 | 1 | -1/+1 |
| | | | | Change-Id: I6527da4b70ebec9e08fa50aca9eba717b8361f19 | ||||
| * | Validate max_records in KafkaConsumer.poll (#1398) | Dana Powers | 2018-02-27 | 1 | -0/+2 |
| | | |||||
| * | Fix KafkaConsumer compacted offset handling (#1397) | Dana Powers | 2018-02-26 | 2 | -10/+28 |
| | | |||||
| * | Fix byte size estimation with kafka producer (#1393) | Blake Embrey | 2018-02-24 | 1 | -1/+1 |
| | | |||||
| * | Fixes racing condition when message is sent to broker before topic logs are ↵ | Andre Araujo | 2018-02-21 | 1 | -3/+19 |
| | | | | | created | ||||
| * | Introduce new fixtures to prepare for migration to pytest. | Andre Araujo | 2018-02-21 | 9 | -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 constructor | Andre Araujo | 2018-02-21 | 1 | -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 SimpleClient | Andre Araujo | 2018-02-21 | 1 | -1/+1 |
| | | |||||
| * | Use hardware accelerated CRC32C function if available (#1389) | Taras Voinarovskyi | 2018-02-21 | 4 | -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 Vickers | 2018-02-21 | 1 | -1/+1 |
| | | |||||
| * | Fix response schema | Alex Eftimie | 2018-02-20 | 1 | -1/+2 |
| | | |||||
| * | Add Admin CreatePartitions API call | Alex Eftimie | 2018-02-20 | 2 | -1/+32 |
| | | |||||
| * | Removed pytest-catchlog dependency | Andre Araujo | 2018-02-12 | 1 | -1/+0 |
| | | | | | | | | | | No longer necessary since pytest-catchlog has been merged into pytest's core. This commit addresses the following warning in pytest output: pytest-catchlog plugin has been merged into the core, please remove it from your requirements. Fixes #1379 | ||||
| * | Bump version for development | Dana Powers | 2018-02-10 | 1 | -1/+1 |
| | | |||||
| * | Patch Release 1.4.1 (#1376)1.4.1 | Dana Powers | 2018-02-09 | 3 | -1/+21 |
| | | |||||
| * | Fix consumer poll stuck error when no available partition (#1375) | Yu Kou | 2018-02-08 | 1 | -1/+1 |
| | | |||||
| * | Increase some integration test timeouts (#1374) | Dana Powers | 2018-02-08 | 5 | -11/+26 |
| | | |||||
| * | Use raw in case string overriden (#1373) | Jeff Widman | 2018-02-08 | 1 | -2/+2 |
| | | |||||
| * | Fix pending completion IndexError bug caused by multiple threads (#1372) | Dana Powers | 2018-02-08 | 1 | -2/+8 |
| | | |||||
| * | Bump version for development of next release | Dana Powers | 2018-02-07 | 1 | -1/+1 |
| | | |||||
| * | Release 1.4.01.4.0 | Dana Powers | 2018-02-07 | 6 | -7/+189 |
| | | |||||
| * | pylint 1.8.2 (#1369) | Dana Powers | 2018-02-06 | 2 | -2/+2 |
| | | |||||
| * | use absolute imports everywhere (#1362) | Kevin Tindall | 2018-02-06 | 43 | -144/+144 |
| | | |||||
| * | Add Request/Response structs for kafka broker 1.0.0 | Dana Powers | 2018-02-06 | 6 | -36/+167 |
| | | |||||
| * | Avoid consuming duplicate compressed messages from mid-batch (#1367) | Dana Powers | 2018-02-05 | 2 | -2/+51 |
| | | |||||
| * | KAFKA-3949: Avoid race condition when subscription changes during rebalance ↵ | Dana Powers | 2018-02-02 | 7 | -109/+128 |
| | | | | | (#1364) | ||||
| * | Add kafka 1.0.0 to travis integration tests | Dana Powers | 2018-02-01 | 1 | -0/+1 |
| | | |||||
| * | Bump `lz4` in `requirements-dev.txt` (#1359) | Jeff Widman | 2018-01-31 | 1 | -1/+1 |
| | | |||||
| * | Use latest pytest 3.4.0, but drop pytest-sugar due to incompatibility (#1361) | Dana Powers | 2018-01-31 | 2 | -3/+1 |
| | | |||||
| * | Stop pinning lz4 | Jeff Widman | 2018-01-26 | 1 | -1/+1 |
| | | | | | | Opening a PR to check if tests pass with the new version. If so, we'll want to bump `requirements-dev.txt` as well. Many thanks to @jonathanunderwood for his diligent work here: https://github.com/dpkp/kafka-python/issues/1021#issuecomment-359161985 | ||||
| * | Use 0.11.0.2 kafka broker for integration testing (#1357) | Dana Powers | 2018-01-25 | 7 | -4/+192 |
| | | |||||
| * | Fix for Python 3 byte string handling in SASL auth (#1353) | Christophe Lecointe | 2018-01-24 | 2 | -2/+4 |
| | | |||||
| * | Remove assertion with side effect (#1348) | Buğra Gedik | 2018-01-23 | 1 | -2/+2 |
| | | |||||
| * | fix reconnect_backoff_max_ms default config bug in KafkaProducer (#1352) | C.YAO | 2018-01-23 | 1 | -1/+1 |
| | | |||||
| * | Name heartbeat thread with group_id; use backoff when polling (#1345) | Dana Powers | 2018-01-16 | 1 | -1/+1 |
| | | |||||
| * | Minor test cleanups (#1343) | Dana Powers | 2018-01-12 | 3 | -2/+5 |
| | | |||||
| * | Avoid KeyError when filtering fetchable partitions (#1344) | Dana Powers | 2018-01-12 | 1 | -2/+2 |
| | | | | | * Avoid KeyError when filtering fetchable partitions | ||||
| * | Honor reconnect_backoff in conn.connect() (#1342) | Dana Powers | 2018-01-11 | 2 | -1/+3 |
| | | | | * Honor reconnect_backoff in conn.connect() | ||||
| * | Fix coordinator join_future race condition (#1338) | Dana Powers | 2018-01-11 | 2 | -4/+21 |
| | | | | * Fix race condition in coordinator join_future handling | ||||
| * | Read all available socket bytes (#1332) | Dana Powers | 2018-01-10 | 4 | -22/+28 |
| | | | | | * Recv all available network bytes before parsing * Add experimental support for configuring socket chunking parameters | ||||
| * | Improve KafkaConsumer cleanup (#1339) | Dana Powers | 2018-01-10 | 5 | -22/+62 |
| | | |||||
| * | Fix typo in _try_authenticate_plain (#1333) | everpcpc | 2017-12-28 | 1 | -1/+1 |
| | | |||||
| * | Add security layer negotiation to the GSSAPI authentication. (#1283) | Andre Araujo | 2017-12-26 | 1 | -22/+43 |
| | | | | | | | | | | | | | | | | | | | When trying to establish a connection with Kafka using SASL with the GSSAPI authentication mechanism the connection was hanging an timing out after 60 secons. On the Kafka broker side I noticed that the SaslServerAuthenticator was going from the AUTHENTICATE to the FAILED state. The GSSAPI auth implementation was missing the second handshake defined in RFC 2222, which happens after the security context is established. This handshake is used by the client and server to negotiate the security layer (QoP) to be used for the connection. Kafka currently only support the "auth" QoP, so the implementation in this commit doesn't make it configurable, but this can be extended later. With this change I was able to successfully connect to a Kerberos-enabled Kafka broker using the SASL_PLAINTEXT protocol and the GSSAPI mechanism. | ||||
| * | Raise non-API exceptions (#1316) | Jeff Widman | 2017-12-21 | 1 | -5/+1 |
| | | | | | | | | | | | | | | The original intent was to catch API exceptions (errors returned by the broker when trying to produce a message) and delegate them to the messages' futures. This is copied from the Java producer. However, we were accidentally catching all exceptions, thereby hiding exceptions from users unless they explicitly check the result of the future. Much better to raise client-side errors directly in the foreground so the user is immediately aware of them and can decide how to handle. Fix #1274 | ||||
| * | KAFKA-3888 Use background thread to process consumer heartbeats (#1266) | Dana Powers | 2017-12-21 | 14 | -738/+977 |
| | | |||||
| * | Pin pylint and lz4 to avoid breaking tests (#1330) | Dana Powers | 2017-12-21 | 2 | -2/+4 |
| | | |||||
| * | Minor Exception cleanup | Jeff Widman | 2017-12-12 | 7 | -10/+10 |
| | | |||||
| * | Use non-deprecated exception handling | Jeff Widman | 2017-12-12 | 1 | -1/+1 |
| | | | | Pulls in the fix upstream from https://github.com/mhils/backports.socketpair/pull/1 | ||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |