delta/python-packages/kafka-python.git/kafka/coordinator, branch master
github.com: mumrah/kafka-python.git
Cover sticky assignor's metadata method with tests (#2161)
2020-11-06T05:00:38+00:00
Valeria Chernenko
aynroot@users.noreply.github.com
2020-11-06T05:00:38+00:00
b090b21f07a1c7b89afb5dc36114aa2d37c580f0
Use six.viewitems instead of six.iteritems to avoid encoding problems (#2154)
2020-10-31T05:31:45+00:00
Valeria Chernenko
aynroot@users.noreply.github.com
2020-10-31T05:31:45+00:00
83b7b2752fecdfef00bb03e7c2a3ac1fe8c2d0d3
KIP-54: Implement sticky partition assignment strategy (#2057)
2020-09-30T04:03:54+00:00
Valeria Chernenko
aynroot@users.noreply.github.com
2020-09-30T04:03:54+00:00
c536dd28bc3c2db85d9b62a1e73d23a3eeaebd93
Fix #1985: fix consumer deadlock when heartbeat thread request timeout (#2064)
2020-09-07T21:59:24+00:00
huangcuiyang
harlan51360@outlook.com
2020-09-07T21:59:24+00:00
91daea329bb40ed80bddef4635770d24b670b0c6
remove unused imports
2020-07-11T05:38:08+00:00
James Lamb
jaylamb20@gmail.com
2020-05-11T04:40:06+00:00
316da747e432962d149828cb9d6fbaff04c2008c
Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979)
2019-12-30T00:06:24+00:00
Dana Powers
dana.powers@gmail.com
2019-12-30T00:06:24+00:00
2a86b23f477e5ed57aa987db97d11284a37d05a0
Log retriable coordinator NodeNotReady, TooManyInFlightRequests as debug not error (#1975)
2019-12-29T23:59:08+00:00
Dana Powers
dana.powers@gmail.com
2019-12-29T23:59:08+00:00
41d9f1c032f8e055685c6f8353e23c2e735211ca
Fix simple typo: managementment -> management
2019-12-09T01:50:34+00:00
Tim Gates
tim.gates@iress.com
2019-12-07T10:10:09+00:00
2ed01e96abd8e2b412aa5228131d531e91c50f76
Closes #1965
Fix typos
2019-11-08T13:21:16+00:00
Carson Ip
carsonip715@gmail.com
2019-10-25T08:41:07+00:00
3861e16ea4ef8d60bc6ffc51c0183da33c629642
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