delta/python-packages/kafka-python.git/test, branch remove-some-unused-code github.com: mumrah/kafka-python.git Remove SimpleClient, Producer, Consumer, Unittest (#1196) 2019-10-11T19:03:22+00:00 Jeff Widman jeff@jeffwidman.com 2019-10-11T19:03:22+00:00 3631bfa009a28767a2057c9beee470acaa6597d5 In the 2.0 release, we're removing: * `SimpleClient` * `SimpleConsumer` * `SimpleProducer` * Old partitioners used by `SimpleProducer`; these are superceded by the `DefaultPartitioner` These have been deprecated for several years in favor of `KafkaClient` / `KafkaConsumer` / `KafkaProducer`. Since 2.0 allows breaking changes, we are removing the deprecated classes. Additionally, since the only usage of `unittest` was in tests for these old Simple* clients, this also drops `unittest` from the library. All tests now run under `pytest`. 
In the 2.0 release, we're removing:
 * `SimpleClient`
 * `SimpleConsumer`
 * `SimpleProducer`
 * Old partitioners used by `SimpleProducer`; these are superceded by
 the `DefaultPartitioner`

These have been deprecated for several years in favor of `KafkaClient`
/ `KafkaConsumer` / `KafkaProducer`.

Since 2.0 allows breaking changes, we are removing the deprecated
classes.

Additionally, since the only usage of `unittest` was in tests for these
old Simple* clients, this also drops `unittest` from the library. All
tests now run under `pytest`.
 Fix describe config for multi-broker clusters (#1869) 2019-10-11T18:46:52+00:00 Jeppe Andersen 2197398+jlandersen@users.noreply.github.com 2019-10-11T18:46:52+00:00 6d3800ca9f45fd953689a1787fc90a5e566e34ea * Fix describe config for multi-broker clusters Currently all describe config requests are sent to "least loaded node". Requests for broker configs must, however, be sent to the specific broker, otherwise an error is returned. Only topic requests can be handled by any node. This changes the logic to send all describe config requests to the specific broker. 
* Fix describe config for multi-broker clusters

Currently all describe config requests are sent to "least loaded node". Requests for broker configs must, however, be sent to the specific broker, otherwise an error is returned. Only topic requests can be handled by any node.

This changes the logic to send all describe config requests to the specific broker.
 convert test_admin_integration to pytest (#1923) 2019-10-07T18:11:58+00:00 Ulrik Johansson ulrik.johansson@gmail.com 2019-10-07T18:11:58+00:00 84e37e0f14b53fbf6fdc2ad97ea1625e50a149d1 






Add KAFKA 2.3.0 to test matrix (#1915)
2019-09-30T20:16:40+00:00

Dana Powers
dana.powers@gmail.com

2019-09-30T20:16:40+00:00

0a8884b984b37a8b46e5b17eabaee894113d7b59












Follow up to PR 1782 -- fix tests (#1914)
2019-09-30T18:18:46+00:00

Dana Powers
dana.powers@gmail.com

2019-09-30T18:18:46+00:00

975087b4ae22ecdb63b757a5abe2e9643888b7fe












Issue #1780 - Consumer hang indefinitely in fetcher._retrieve_offsets() due to topic deletion while rebalancing  (#1782)
2019-09-30T14:23:06+00:00

Commander Dishwasher
roy.antman@gmail.com

2019-09-30T14:23:06+00:00

298cb0dbef58f6bb267235911b6ca86039bf8cda












Send socket data via non-blocking IO with send buffer (#1912)
2019-09-30T00:04:17+00:00

Dana Powers
dana.powers@gmail.com

2019-09-30T00:04:17+00:00

392d674be6641078717a4d87e471916c9a4bbb22












Do not use wakeup when sending fetch requests from consumer (#1911)
2019-09-29T14:56:12+00:00

Dana Powers
dana.powers@gmail.com

2019-09-29T14:56:12+00:00

9de12d3f03236988a60e6cd79a50ffa5165cf735












Rely on socket selector to detect completed connection attempts (#1909)
2019-09-29T02:30:09+00:00

Dana Powers
dana.powers@gmail.com

2019-09-29T02:30:09+00:00

89bf6a6ee51e8a54f909eae4785d04e485b91198












Skip admin integration tests -- travis fixture issues
2019-09-29T01:18:06+00:00

Dana Powers
dana.powers@gmail.com

2019-09-29T01:18:06+00:00

a9f513cf9978b8b9f26ad04bba1d33a9ae6d1b99