delta/python-packages/kafka-python.git/test, branch break-consumer-operations-into-request-response-methods

Sanity test for consumer.topics() and consumer.partitions_for_topic()

2019-06-05T05:53:45+00:00

Reduce client poll timeout when no ifrs

2019-05-30T04:46:37+00:00

Update docs for api_version_auto_timeout_ms (#1812)

2019-05-24T07:15:58+00:00

The docs for `api_version_auto_timeout_ms` mention setting
`api_version='auto'` but that value has been deprecated for years in
favor of `api_version=None`.

Updating the docs for now, and will remove support for `'auto'` in next
major version bump.

Remove unused imports (#1808)

2019-05-23T04:56:25+00:00

Do not call state_change_callback with lock (#1775)

2019-04-03T04:27:49+00:00

Dont treat popped conn.close() as failure in state change callback (#1773)

2019-04-02T02:38:48+00:00

Dont wakeup during maybe_refresh_metadata -- it is only called by poll() (#1769)

2019-03-31T02:29:30+00:00

Fix flaky conn tests that use time.time (#1758)

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

Generate SSL certificates for local testing (#1756)

2019-03-21T19:19:39+00:00

This doesn't fully implement SSL fixtures, but as a first step it should help with automatically generating required certificates / keystores / etc. My hope is that this helps generate more community support for SSL testing!

Error if connections_max_idle_ms not larger than request_timeout_ms (#1688)

2019-03-15T00:34:59+00:00