diff options
| author | Dana Powers <dana.powers@rd.io> | 2018-03-07 17:08:57 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2018-03-07 17:08:57 -0800 |
| commit | 33577d8d1e5fe201adc61b4c1661396c729ae0c0 (patch) | |
| tree | c24669818a845ebfa73e1333b857dea8b2d1a22e | |
| parent | 3ccd6638f03d64d30ecc4e17014f51387804d974 (diff) | |
| download | kafka-python-close_consumer_tests.tar.gz | |
Fix merge conflictclose_consumer_tests
| -rw-r--r-- | test/test_consumer_integration.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_consumer_integration.py b/test/test_consumer_integration.py index 6429b77..78a8a3c 100644 --- a/test/test_consumer_integration.py +++ b/test/test_consumer_integration.py @@ -44,7 +44,7 @@ def test_kafka_consumer(simple_client, topic, kafka_consumer_factory): assert len(messages[0]) == 100 assert len(messages[1]) == 100 - consumer.close() + kafka_consumer.close() class TestConsumerIntegration(KafkaIntegrationTestCase): |