delta/python-packages/kafka-python.git/kafka, branch selector_close

Close leaked selector in version check

2018-03-09T00:55:17+00:00

Avoid tight poll loop in consumer when brokers are down (#1415)

2018-03-08T16:18:15+00:00

Fix BrokerConnection.connection_delay() to return milliseconds (#1414)

2018-03-08T16:17:36+00:00

Use local copies in Fetcher._fetchable_partitions to avoid mutation errors (#1400)

2018-03-08T01:07:09+00:00

Fix error var name in _unpack (#1403)

2018-03-05T09:34:27+00:00

Change-Id: I6527da4b70ebec9e08fa50aca9eba717b8361f19

Validate max_records in KafkaConsumer.poll (#1398)

2018-02-27T17:30:47+00:00

Fix KafkaConsumer compacted offset handling (#1397)

2018-02-26T23:03:10+00:00

Fix byte size estimation with kafka producer (#1393)

2018-02-24T16:14:09+00:00

Check timeout type in KafkaClient constructor

2018-02-21T21:30:12+00:00

If a future was passed as the only positional parameter it would
be assigned to the "timeout_ms" parameter erroneously. This mistake
would not raise any exception but would lead to odd behaviour later,
what could make it extremely difficult to troubleshoot.

Adding a type check ensures that an exception is raise earlier to
notify the user about the problem.

Update string representation of SimpleClient

2018-02-21T21:30:12+00:00