delta/python-packages/kafka-python.git/kafka/client_async.py, branch add-python-37-support github.com: mumrah/kafka-python.git Do network connections and writes in KafkaClient.poll() (#1729) 2019-03-08T16:01:48+00:00 Dana Powers dana.powers@gmail.com 2019-03-08T16:01:48+00:00 8c0792581d8a38822c01b40f5d3926c659b0c439 * Add BrokerConnection.send_pending_requests to support async network sends * Send network requests during KafkaClient.poll() rather than in KafkaClient.send() * Dont acquire lock during KafkaClient.send if node is connected / ready * Move all network connection IO into KafkaClient.poll() 
* Add BrokerConnection.send_pending_requests to support async network sends
* Send network requests during KafkaClient.poll() rather than in KafkaClient.send()
* Dont acquire lock during KafkaClient.send if node is connected / ready
* Move all network connection IO into KafkaClient.poll()
 Do not require client lock for read-only operations (#1730) 2019-03-07T03:11:23+00:00 Dana Powers dana.powers@gmail.com 2019-03-07T03:11:23+00:00 7a99013668b798aaa0acffcf382a7e48e7bd41c1 In an effort to reduce the surface area of lock coordination, and thereby hopefully reduce lock contention, I think we can remove locking from the read-only KafkaClient methods: connected, is_disconnected, in_flight_request_count, and least_loaded_node . Given that the read data could change after the lock is released but before the caller uses it, the value of acquiring a lock here does not seem high to me. 
In an effort to reduce the surface area of lock coordination, and thereby hopefully reduce lock contention, I think we can remove locking from the read-only KafkaClient methods: connected, is_disconnected, in_flight_request_count, and least_loaded_node . Given that the read data could change after the lock is released but before the caller uses it, the value of acquiring a lock here does not seem high to me.
 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