delta/python-packages/kafka-python.git/test, branch bootstrap_cluster_metadata github.com: mumrah/kafka-python.git Improve bootstrap handling, retries, dns lookups 2019-03-14T01:36:54+00:00 Dana Powers dana.powers@gmail.com 2019-03-14T01:31:14+00:00 0e541e2f03cee2825fbff534ee9a337220ed08a2 






Synchronize puts to KafkaConsumer protocol buffer during async sends
2019-03-12T20:36:52+00:00

Dana Powers
dana.powers@gmail.com

2019-03-12T04:48:31+00:00

2a91ca1a8fd767d2e1f9981c7431ce31dcbddf00












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()






Use test.fixtures.version not test.conftest.version to avoid warnings (#1731)
2019-03-07T03:10:29+00:00

Dana Powers
dana.powers@gmail.com

2019-03-07T03:10:29+00:00

37699be51f868bd736e0fd595f2afc4c03b00ca4












Fix test_legacy_correct_metadata_response on x86 arch (#1718)
2019-02-21T09:04:59+00:00

Stanislav Levin
31205609+stanislavlevin@users.noreply.github.com

2019-02-21T09:04:59+00:00

03664ebe9ed8bc965391f925d50219eea4d6ac57

The problem is that the type of required operation result is
"long".

```
>>> type(278251978 & 0xffffffff)
<type 'long'>
```

However, by default "format" method uses __format__():

```
>>> (278251978 & 0xffffffff).__format__('')
'278251978'
```

So, let's compare things using the same engine:

```
>>> "{!r}".format(278251978 & 0xffffffff)
'278251978L'
```

Fixes: https://github.com/dpkp/kafka-python/issues/1717
Signed-off-by: Stanislav Levin <slev@altlinux.org>




The problem is that the type of required operation result is
"long".

```
>>> type(278251978 & 0xffffffff)
<type 'long'>
```

However, by default "format" method uses __format__():

```
>>> (278251978 & 0xffffffff).__format__('')
'278251978'
```

So, let's compare things using the same engine:

```
>>> "{!r}".format(278251978 & 0xffffffff)
'278251978L'
```

Fixes: https://github.com/dpkp/kafka-python/issues/1717
Signed-off-by: Stanislav Levin <slev@altlinux.org>






Use Popen.communicate() instead of Popen.wait()
2019-01-05T22:38:53+00:00

Brian Sang
sang.bri@gmail.com

2019-01-05T06:16:28+00:00

d2f9413b0311e6ec4d782cf9983f61c9f258cc7b

Popen objects may deadlock when using stdout=PIPE or stderr=PIPE
with Popen.wait(). Using Popen.communicate() avoids the issue.





Popen objects may deadlock when using stdout=PIPE or stderr=PIPE
with Popen.wait(). Using Popen.communicate() avoids the issue.







Cleanup formatting, no functional changes
2018-11-20T19:00:24+00:00

Jeff Widman
jeff@jeffwidman.com

2018-11-20T17:30:31+00:00

7444e07011cc5374d1fbdff422f868241f4d1e77

Cleanup the formatting, remove parens, extraneous spaces, etc.





Cleanup the formatting, remove parens, extraneous spaces, etc.







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







Migrate from `Unittest` to `pytest` (#1620)
2018-11-10T20:48:33+00:00

Jeff Widman
jeff@jeffwidman.com

2018-11-10T20:48:33+00:00

bb5bc1fcfc09c9c9994edbbae0af2ff6802c353d












Cleanup fixture imports
2018-10-27T09:17:23+00:00

Jeff Widman
jeff@jeffwidman.com

2018-10-27T07:11:10+00:00

f00016e7cec64cfc9697b233809cd37e0e19cc64

`random_string` now comes from `test.fixtures` and was being
transparently imported via `test.testutil` so this bypasses the
pointless indirect import.

Similarly, `kafka_version` was transparently imported by `test.testutil`
from `test.fixtures`.

Also removed `random_port()` in `test.testutil` because its unused as its been replaced
by the one in `test.fixtures`.

This is part of the pytest migration that was started back in
a1869c4be5f47b4f6433610249aaf29af4ec95e5.





`random_string` now comes from `test.fixtures` and was being
transparently imported via `test.testutil` so this bypasses the
pointless indirect import.

Similarly, `kafka_version` was transparently imported by `test.testutil`
from `test.fixtures`.

Also removed `random_port()` in `test.testutil` because its unused as its been replaced
by the one in `test.fixtures`.

This is part of the pytest migration that was started back in
a1869c4be5f47b4f6433610249aaf29af4ec95e5.