From 33577d8d1e5fe201adc61b4c1661396c729ae0c0 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 7 Mar 2018 17:08:57 -0800 Subject: Fix merge conflict --- test/test_consumer_integration.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'test/test_consumer_integration.py') 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): -- cgit v1.2.1