delta/python-packages/kafka-python.git/kafka, branch master github.com: mumrah/kafka-python.git Allow disabling thread wakeup in send_request_to_node (#2335) 2023-03-02T20:25:13+00:00 Andrew Zhang andrew.zhang@datadoghq.com 2023-03-02T20:25:13+00:00 7ac6c6e29099ccba4d50f5b842972dd7332d0e58 






Fix producerconfigs documentation link (#2226)
2021-08-03T19:54:21+00:00

MandarJKulkarni
33712629+MandarJKulkarni@users.noreply.github.com

2021-08-03T19:54:21+00:00

f0a57a6a20a3049dc43fbf7ad9eab9635bd2c0b0












Fix typo: veriication -> verification (#2207)
2021-02-22T05:44:42+00:00

Dongwook Chan
dongwook.chan@gmail.com

2021-02-22T05:44:42+00:00

f19e4238fb47ae2619f18731f0e0e9a3762cfa11

Co-authored-by: will.k <will.k@kakaocorp.com>




Co-authored-by: will.k <will.k@kakaocorp.com>






fix typo in documentation (#2178)
2021-02-20T22:18:49+00:00

Nikolay Vasiliev
lonlylocly@yandex.ru

2021-02-20T22:18:49+00:00

6521c1d5ee9cdc2e9d7ee373015ccd639525d350












Core Protocol: Add support for flexible versions (#2151)
2020-12-02T14:45:13+00:00

Tincu Gabriel
gabi@aiven.io

2020-12-02T14:45:13+00:00

9feeb79140ed10e3a7f2036491fc07573740c231

- Add support for new request and response headers, supporting flexible
versions / tagged fields
- Add List / Alter partition reassignments APIs
- Add support for varints
- Add support for compact collections (byte array, string, array)




- Add support for new request and response headers, supporting flexible
versions / tagged fields
- Add List / Alter partition reassignments APIs
- Add support for varints
- Add support for compact collections (byte array, string, array)






Support configuration of custom kafka client for Admin/Consumer/Producer (#2144)
2020-12-02T14:37:38+00:00

Tincu Gabriel
gabi@aiven.io

2020-12-02T14:37:38+00:00

c48817e0d21d7752077e28f2ea9a657b9001a14b












Hotfix: TypeError: object of type 'dict_itemiterator' has no len() (#2167)
2020-11-19T21:51:14+00:00

Krzysztof Grabowski
koras@indywidualni.org

2020-11-19T21:51:14+00:00

53dc740bce8ef19c32fad2881021d1f6bb055f7a

* Hotfix: TypeError: object of type 'dict_itemiterator' has no len()

* Avoid looping over items 2x

Co-authored-by: Grabowski <chris@crawlinski.com>




* Hotfix: TypeError: object of type 'dict_itemiterator' has no len()

* Avoid looping over items 2x

Co-authored-by: Grabowski <chris@crawlinski.com>






Add Kafka 2.6.0 to tests and protocol compatibility matrix (#2162)
2020-11-15T19:50:46+00:00

Lourens Naudé
lourens@methodmissing.com

2020-11-15T19:50:46+00:00

8b8a48ba09677e38088c61ade2dab2e42198ab3f

* Co-authored-by: Andrew Brown <andrew.brown@shopify.com>
* Co-authored-by: Aaron Brady <aaron.brady@shopify.com>




* Co-authored-by: Andrew Brown <andrew.brown@shopify.com>
* Co-authored-by: Aaron Brady <aaron.brady@shopify.com>






KafkaConsumer: Exit poll if consumer is closed (#2152)
2020-11-15T18:19:58+00:00

Rauli Ikonen
rauli@aiven.io

2020-11-15T18:19:58+00:00

6c87155bbd855f6bba1ba30b2b6227e66ea79baa












Only try to update sensors fetch lag if the unpacked list contains elements (#2158)
2020-11-06T05:05:55+00:00

Keith So
kso@eclipseoptions.com

2020-11-06T05:05:55+00:00

12325c09baefae2396f1083bc8b037603721198c

Previously, if the `unpacked` list was empty, the call to `unpacked[-1]` would throw an `IndexError: list index out of range`




Previously, if the `unpacked` list was empty, the call to `unpacked[-1]` would throw an `IndexError: list index out of range`