test: increate timeouts

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(5))
         .build(RecordAggregator::new(record.approximate_size() * 2 + 1));
 
     let a = producer.produce(record.clone()).fuse();
@@ -48,15 +48,15 @@ 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(4_000)).fuse() => break
         };
     }
 
     assert!(a.is_terminated());
     assert!(b.is_terminated());
 
     // Third record should eventually be published
-    tokio::time::timeout(Duration::from_secs(5), c)
+    tokio::time::timeout(Duration::from_secs(6), c)
         .await
         .expect("no timeout")
         .unwrap();