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

More thorough IPv6 support that uses getaddrinfo to resolve names

2016-04-24T23:20:22+00:00

Fixes #641

instrument metrics for fetch requests

2016-04-14T00:26:39+00:00

Beginnings of metrics instrumentation in kafka consumer.

2016-04-14T00:26:39+00:00

This adds the parent metrics instance to kafka consumer, which will
eventually be used to instrument everything under consumer. To start
I ported the java consumer coordinator metrics.

Basic dictionary reporter in place of the java JMX reporter.

2016-04-14T00:26:39+00:00

Kafka metrics java port. No reporters or instrumentation.

2016-04-14T00:26:38+00:00

There is no straight translation for the JMX reporter into python,
so I'll do something else in a separate commit.

Attempt to add ssl support to kafka fixtures

2016-04-09T16:24:40+00:00

Update conn fixture to check for HANDSHAKE state

2016-04-09T16:24:39+00:00

Use selectors module in KafkaClient

2016-04-09T15:03:09+00:00

Add state_change_callback to bootstrap connection

2016-04-08T22:57:47+00:00

Move state logic from KafkaClient._maybe_connect to _conn_state_change as callback

2016-04-08T22:56:24+00:00