diff options
| author | Dana Powers <dana.powers@gmail.com> | 2015-03-30 17:42:51 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2015-03-30 17:42:51 -0700 |
| commit | 9fd08119170b64c56ea024d12ef6b0e6482d778b (patch) | |
| tree | 5fb240b11a7f9e7a5ca9d2c348556967b0f94b0c /test/test_failover_integration.py | |
| parent | 6fc6856746c9e27d4c96b47b1941b6ebbabcb33b (diff) | |
| parent | 1d252bfc20c8b1058dc93a495c3bdb0f4ccdf590 (diff) | |
| download | kafka-python-9fd08119170b64c56ea024d12ef6b0e6482d778b.tar.gz | |
Merge pull request #356 from dpkp/always_fetch_offsets
fetch commit offsets in base consumer unless group is None
Diffstat (limited to 'test/test_failover_integration.py')
| -rw-r--r-- | test/test_failover_integration.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_failover_integration.py b/test/test_failover_integration.py index 7d27526..15f0338 100644 --- a/test/test_failover_integration.py +++ b/test/test_failover_integration.py @@ -183,7 +183,7 @@ class TestFailover(KafkaIntegrationTestCase): client = KafkaClient(hosts) group = random_string(10) - consumer = SimpleConsumer(client, group, topic, + consumer = SimpleConsumer(client, None, topic, partitions=partitions, auto_commit=False, iter_timeout=timeout) |