diff options
| -rw-r--r-- | test/test_producer_integration.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/test/test_producer_integration.py b/test/test_producer_integration.py index 2b81047..6533cfa 100644 --- a/test/test_producer_integration.py +++ b/test/test_producer_integration.py @@ -294,6 +294,7 @@ class TestKafkaProducerIntegration(KafkaIntegrationTestCase): producer.stop() def test_batched_simple_producer__triggers_by_time(self): + self.skipTest("Flakey test -- should be refactored or removed") partitions = self.client.get_partition_ids_for_topic(self.topic) start_offsets = [self.current_offset(self.topic, p) for p in partitions] |