diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-09 15:51:11 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-09 15:51:11 -0800 |
| commit | 98f393ba6f8dda107c464069fa846e390aee9b42 (patch) | |
| tree | e89b4f6460aef4184f5fbf47ebf0332d7deefd8f | |
| parent | f304fb6c4d37a54d142a83e9f654d098347a0750 (diff) | |
| download | kafka-python-98f393ba6f8dda107c464069fa846e390aee9b42.tar.gz | |
Default consumer integration tests should not use offset commits
| -rw-r--r-- | test/test_consumer_integration.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/test/test_consumer_integration.py b/test/test_consumer_integration.py index d536537..17c5844 100644 --- a/test/test_consumer_integration.py +++ b/test/test_consumer_integration.py @@ -60,10 +60,11 @@ class TestConsumerIntegration(KafkaIntegrationTestCase): kwargs['group'] = None kwargs['auto_commit'] = False else: - kwargs.setdefault('auto_commit', True) + kwargs.setdefault('group', None) + kwargs.setdefault('auto_commit', False) consumer_class = kwargs.pop('consumer', SimpleConsumer) - group = kwargs.pop('group', self.id().encode('utf-8')) + group = kwargs.pop('group', None) topic = kwargs.pop('topic', self.topic) if consumer_class in [SimpleConsumer, MultiProcessConsumer]: |