delta/python-packages/kafka-python.git/test, branch kafka-3318

KAFKA-3318: clean up consumer logging and error messages

2016-04-05T17:22:54+00:00

Update imports from kafka.common -> kafka.errors / kafka.structs

2016-04-05T16:35:45+00:00

Add BrokerConnection.send tests

2016-04-05T07:16:15+00:00

Merge pull request #589 from dpkp/node_not_ready

2016-04-04T23:09:10+00:00

Refactor NodeNotReadyError handling

Improve KafkaClient connect and ready handling

2016-04-04T21:42:50+00:00

 - merge _initiate and _finish into _maybe_connect
 - add connected(node_id) method
 - only short-circuit send() when not connected

Add basic unit test coverage for BrokerConnection

2016-04-04T21:42:49+00:00

Move old KafkaConnection tests to test_conn_legacy

2016-04-04T16:19:51+00:00

Test _maybe_auto_commit_offsets_sync when group_id is None

2016-04-03T16:28:21+00:00

Kafka IPv6 Support.

2016-03-30T22:32:25+00:00

IPv6 address without port can be defined as the IPv6 address.  If the address
is a hostname or if a port is included, then the address MUST be wrapped
in brackets [] (E.g. [somehost]:1234 or [fd00:1001::2]:1234).

Merge pull request #603 from dpkp/windows

2016-03-24T17:19:29+00:00

Updates to support Windows