diff options
Diffstat (limited to 'test/test_consumer_integration.py')
| -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): |