summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2018-04-18 15:10:33 -0700
committerDana Powers <dana.powers@gmail.com>2018-04-18 15:10:33 -0700
commitb6ffbaaab2a26f8a12db195630dd5fa0a0fb2a35 (patch)
tree1751a2d745fdded259e2f98226226aa1fe74bd56
parent59b0c6f714f83b5dae2df97f12645c39a6cdc179 (diff)
downloadkafka-python-b6ffbaaab2a26f8a12db195630dd5fa0a0fb2a35.tar.gz
Skip flakey SimpleProducer test
-rw-r--r--test/test_producer_integration.py1
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]