diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-09-28 12:39:34 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-09-28 12:39:34 -0700 |
| commit | 9ee77dfdbc4aeb5723ce7ebdae76f8b7141962af (patch) | |
| tree | ae679983f7206ff6d0058fa551aa4f8380612e42 /test/test_consumer_integration.py | |
| parent | b8717b4b79462e83344f49bbd42312cf521d84aa (diff) | |
| download | kafka-python-9ee77dfdbc4aeb5723ce7ebdae76f8b7141962af.tar.gz | |
KAFKA-3007: KafkaConsumer max_poll_records (#831)
Diffstat (limited to 'test/test_consumer_integration.py')
| -rw-r--r-- | test/test_consumer_integration.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/test/test_consumer_integration.py b/test/test_consumer_integration.py index 9c27eee..998045f 100644 --- a/test/test_consumer_integration.py +++ b/test/test_consumer_integration.py @@ -500,6 +500,7 @@ class TestConsumerIntegration(KafkaIntegrationTestCase): def test_kafka_consumer__blocking(self): TIMEOUT_MS = 500 consumer = self.kafka_consumer(auto_offset_reset='earliest', + enable_auto_commit=False, consumer_timeout_ms=TIMEOUT_MS) # Manual assignment avoids overhead of consumer group mgmt |