From 3df9e400d793e91f18a9927a50e17954b6ad2d59 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Thu, 8 Feb 2018 15:57:08 -0800 Subject: Increase test_producer end-to-end timeouts --- test/test_producer.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/test/test_producer.py b/test/test_producer.py index f7a5b68..80017a1 100644 --- a/test/test_producer.py +++ b/test/test_producer.py @@ -38,12 +38,12 @@ def test_end_to_end(kafka_broker, compression): connect_str = ':'.join([kafka_broker.host, str(kafka_broker.port)]) producer = KafkaProducer(bootstrap_servers=connect_str, retries=5, - max_block_ms=10000, + max_block_ms=30000, compression_type=compression, value_serializer=str.encode) consumer = KafkaConsumer(bootstrap_servers=connect_str, group_id=None, - consumer_timeout_ms=10000, + consumer_timeout_ms=30000, auto_offset_reset='earliest', value_deserializer=bytes.decode) @@ -87,7 +87,7 @@ def test_kafka_producer_proper_record_metadata(kafka_broker, compression): connect_str = ':'.join([kafka_broker.host, str(kafka_broker.port)]) producer = KafkaProducer(bootstrap_servers=connect_str, retries=5, - max_block_ms=10000, + max_block_ms=30000, compression_type=compression) magic = producer._max_usable_produce_magic() -- cgit v1.2.1