delta/python-packages/kafka-python.git/test/test_coordinator.py, branch 1.2.5

enable errors on callbacks in testing. fix broken test.

2016-04-25T21:48:50+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.

Consolidate conn fixture definitions

2016-04-07T16:49:05+00:00

Use version-indexed lists for request/response protocol structs

2016-04-06T05:54:28+00:00

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

Test _maybe_auto_commit_offsets_sync when group_id is None

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

Add test for unknown coordinator heartbeat task

2016-03-12T23:08:36+00:00

Mock client.ready() call to test coordinator offset fetch request

2016-02-19T15:56:44+00:00

break up some circular references and close client wake pipe on del

2016-02-17T05:30:38+00:00