delta/python-packages/kafka-python.git/kafka/client_async.py, branch fix_fixture_version_warning github.com: mumrah/kafka-python.git Break KafkaClient poll if closed 2018-11-20T16:20:17+00:00 Dana Powers dana.powers@gmail.com 2018-11-20T16:20:17+00:00 2c77c8d73c3bb81011b3440b1f0308fd48d0e627 






Be explicit with tuples for %s formatting
2018-11-18T08:21:18+00:00

Jeff Widman
jeff@jeffwidman.com

2018-11-13T19:57:45+00:00

1d443638e22c2d360086b8d7cee8b5d930741d12

Fix #1633





Fix #1633







Use TypeError for invalid type
2018-11-17T08:41:24+00:00

Jeff Widman
jeff@jeffwidman.com

2018-11-13T21:58:51+00:00

21d68c98470eab6b9e7e5c934017af4a4fd24748












set socket timeout for the wake_w (#1577)
2018-11-10T20:45:51+00:00

flaneur
me.ssword@gmail.com

2018-11-10T20:45:51+00:00

1c0e8942dc75837a2e43b93e0ed6700fb7752a03












(Attempt to) Fix deadlock between consumer and heartbeat (#1628)
2018-11-10T20:45:01+00:00

Dana Powers
dana.powers@gmail.com

2018-11-10T20:45:01+00:00

0a2ccba3cb1b8636f615a30821123720773a8dfa












Add KafkaAdmin class
2018-10-25T05:42:12+00:00

Richard Lee
github@richardlee.name

2018-07-12T18:39:29+00:00

481f88068bdf0a18f12fd7a811b795f889d35fc7

Requires cluster version > 0.10.0.0, and uses new wire protocol
classes to do many things via broker connection that previously
needed to be done directly in zookeeper.





Requires cluster version > 0.10.0.0, and uses new wire protocol
classes to do many things via broker connection that previously
needed to be done directly in zookeeper.







add kerberos domain name config for gssapi sasl mechanism handshake (#1542)
2018-08-31T13:03:26+00:00

the-sea
huhaiyang2@huawei.com

2018-08-31T13:03:26+00:00

36b53f487778e919dfe6a5940dc25c552444cc7c












add support for smaller topic metadata fetch during bootstrap (#1541)
2018-08-31T13:01:46+00:00

Ning Xie
andy.xning@gmail.com

2018-08-31T13:01:46+00:00

a7d3063d5fa1c3cb2a76c16231bb3028a6f8cde9












Document connections_max_idle_ms
2018-06-26T19:48:41+00:00

Jeff Widman
jeff@jeffwidman.com

2018-06-26T19:47:12+00:00

9ac3cb1ec220ff9968a8b003b02e98dd11cc486b

This was added in #1068 but never documented.
Fix #1497





This was added in #1068 but never documented.
Fix #1497







Stop shadowing `ConnectionError`
2018-05-23T22:19:01+00:00

Jeff Widman
jeff@jeffwidman.com

2018-05-10T23:12:19+00:00

11cf3973bfc64ab0b4e471fc56dae911df1ec8d9

In Python3, `ConnectionError` is a native exception. So rename our
custom one to `KafkaConnectionError` to prevent accidentally
shadowing the native one.

Note that there are still valid uses of `ConnectionError` in this code.
They already expect a native Python3 `ConnectionError`, and also already
handle the Python2 compatibility issues.





In Python3, `ConnectionError` is a native exception. So rename our
custom one to `KafkaConnectionError` to prevent accidentally
shadowing the native one.

Note that there are still valid uses of `ConnectionError` in this code.
They already expect a native Python3 `ConnectionError`, and also already
handle the Python2 compatibility issues.