delta/python-packages/kafka-python.git/test/test_conn.py, branch 2.0.2 github.com: mumrah/kafka-python.git Rely on socket selector to detect completed connection attempts (#1909) 2019-09-29T02:30:09+00:00 Dana Powers dana.powers@gmail.com 2019-09-29T02:30:09+00:00 89bf6a6ee51e8a54f909eae4785d04e485b91198 






Minor test cleanup (#1885)
2019-08-22T01:47:22+00:00

Jeff Widman
jeff@jeffwidman.com

2019-08-22T01:47:22+00:00

e49caeb3ebdd36eb4d18a517bc402f8e89dfdbee

Remove unused import, whitespace, etc. No functional changes, just
cleaning it up so the diffs of later changes are cleaner.




Remove unused import, whitespace, etc. No functional changes, just
cleaning it up so the diffs of later changes are cleaner.






tests: Use socket.SOCK_STREAM in assertions
2019-08-15T18:36:05+00:00

Ivan A. Melnikov
iv@altlinux.org

2019-08-12T07:42:06+00:00

2180d312c36e62c7175c112b38cbde79c3c90377

socket.SOCK_STREAM is platform specific and on some
platforms (most notably on Linux on MIPS) does not
equal 1; so it's better to use the constant where
appropriate.

This change fixes the tests on my MIPS32 LE machine.

Signed-off-by: Ivan A. Melnikov <iv@altlinux.org>





socket.SOCK_STREAM is platform specific and on some
platforms (most notably on Linux on MIPS) does not
equal 1; so it's better to use the constant where
appropriate.

This change fixes the tests on my MIPS32 LE machine.

Signed-off-by: Ivan A. Melnikov <iv@altlinux.org>







Fix flaky conn tests that use time.time (#1758)
2019-03-22T05:48:11+00:00

Dana Powers
dana.powers@gmail.com

2019-03-22T05:48:11+00:00

d032844ad945b6e99845c40cfe08e026a56d332a












Mock dns lookups in test_conn (#1739)
2019-03-14T04:43:29+00:00

Dana Powers
dana.powers@gmail.com

2019-03-14T04:43:29+00:00

39dd8c28da133fcc5005db3db127d687882dfe99

Small change to avoid doing dns resolution when running local connection tests. This fixture always returns a broker on localhost:9092, so DNS lookups don't make sense here.




Small change to avoid doing dns resolution when running local connection tests. This fixture always returns a broker on localhost:9092, so DNS lookups don't make sense here.






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












Don't use `kafka.common` internally
2018-06-05T21:32:01+00:00

Jeff Widman
jeff@jeffwidman.com

2018-05-28T22:58:26+00:00

bc4cc434cddf403a35d0393d68ecfdbfad17c8e5

This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.





This finishes the split from `kafka.common` to `kafka.errors`/`kafka.structs`.







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.







Connect with sockaddrs to support non-zero ipv6 scope ids (#1433)
2018-03-10T00:59:06+00:00

Dana Powers
dana.powers@gmail.com

2018-03-10T00:59:06+00:00

acbc346ddb34d2f722beaf5296dddcc12f38e2d6












Make BrokerConnection .host / .port / .afi immutable, use _sock_* attributes for current lookups (#1422)
2018-03-09T15:17:43+00:00

Dana Powers
dana.powers@gmail.com

2018-03-09T15:17:43+00:00

ce96752c3d4ca53222aebe1f824a47865bcb3aff