diff options
| author | Dana Powers <dana.powers@gmail.com> | 2018-02-08 15:57:08 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2018-02-08 15:57:08 -0800 |
| commit | 3df9e400d793e91f18a9927a50e17954b6ad2d59 (patch) | |
| tree | 52e8947b5fe837b83af7cd18f11af79911c167c6 | |
| parent | dd9aa8031755dafda27eec4c938a3f7271f15afb (diff) | |
| download | kafka-python-cleanups.tar.gz | |
Increase test_producer end-to-end timeoutscleanups
| -rw-r--r-- | test/test_producer.py | 6 |
1 files 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() |