test: increate timeouts

influxdata · Jan 14, 2022 · 1948b1d · 1948b1d
1 parent 65161d6
commit 1948b1d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tests/producer.rs b/tests/producer.rs
@@ -24,7 +24,7 @@ async fn test_batch_producer() {
 
     let partition_client = Arc::new(client.partition_client(&topic, 0).await.unwrap());
     let producer = BatchProducerBuilder::new(partition_client)
-        .with_linger(Duration::from_secs(2))
+        .with_linger(Duration::from_secs(3))
         .build(RecordAggregator::new(record.approximate_size() * 2 + 1));
 
     let a = producer.produce(record.clone()).fuse();
@@ -48,7 +48,7 @@ async fn test_batch_producer() {
             r = a => r.unwrap(),
             r = b => r.unwrap(),
             _ = c => panic!("c finished!"),
-            _ = tokio::time::sleep(Duration::from_millis(1_000)).fuse() => break
+            _ = tokio::time::sleep(Duration::from_millis(2_000)).fuse() => break
         };
     }