Skip MultiProcessConsumer integration tests

dpkp · dpkp · commit 47da03d90ff1 · 2016-01-30T14:07:39.000-08:00
diff --git a/test/test_consumer_integration.py b/test/test_consumer_integration.py
@@ -240,6 +240,7 @@ def test_simple_consumer_pending(self):
         self.assertEquals(set([0, 1]), set([pending_part1, pending_part2]))
         consumer.stop()
 
+    @unittest.skip('MultiProcessConsumer deprecated and these tests are flaky')
     def test_multi_process_consumer(self):
         # Produce 100 messages to partitions 0 and 1
         self.send_messages(0, range(0, 100))
@@ -251,6 +252,7 @@ def test_multi_process_consumer(self):
 
         consumer.stop()
 
+    @unittest.skip('MultiProcessConsumer deprecated and these tests are flaky')
     def test_multi_process_consumer_blocking(self):
         consumer = self.consumer(consumer = MultiProcessConsumer)
 
@@ -288,6 +290,7 @@ def test_multi_process_consumer_blocking(self):
 
         consumer.stop()
 
+    @unittest.skip('MultiProcessConsumer deprecated and these tests are flaky')
     def test_multi_proc_pending(self):
         self.send_messages(0, range(0, 10))
         self.send_messages(1, range(10, 20))
@@ -303,6 +306,7 @@ def test_multi_proc_pending(self):
 
         consumer.stop()
 
+    @unittest.skip('MultiProcessConsumer deprecated and these tests are flaky')
     @kafka_versions('>=0.8.1')
     def test_multi_process_consumer_load_initial_offsets(self):
         self.send_messages(0, range(0, 10))
@@ -399,6 +403,7 @@ def test_offset_behavior__resuming_behavior(self):
         consumer1.stop()
         consumer2.stop()
 
+    @unittest.skip('MultiProcessConsumer deprecated and these tests are flaky')
     @kafka_versions('>=0.8.1')
     def test_multi_process_offset_behavior__resuming_behavior(self):
         self.send_messages(0, range(0, 100))
