backend: increase produce timeouts in deserializer integration tests

redpanda-data · Aug 1, 2023 · 0cb8fa1 · 0cb8fa1
1 parent 6abe0a4
commit 0cb8fa1
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/backend/pkg/kafka/deserializer_integration_test.go b/backend/pkg/kafka/deserializer_integration_test.go
@@ -169,7 +169,7 @@ func (s *KafkaIntegrationTestSuite) TestDeserializeRecord() {
 			Timestamp: recordTimeStamp,
 		}
 
-		produceCtx, produceCancel := context.WithTimeout(context.Background(), 1*time.Second)
+		produceCtx, produceCancel := context.WithTimeout(context.Background(), 3*time.Second)
 		defer produceCancel()
 
 		results := s.kafkaClient.ProduceSync(produceCtx, r)
@@ -257,7 +257,7 @@ func (s *KafkaIntegrationTestSuite) TestDeserializeRecord() {
 			Timestamp: orderCreatedAt,
 		}
 
-		produceCtx, produceCancel := context.WithTimeout(context.Background(), 1*time.Second)
+		produceCtx, produceCancel := context.WithTimeout(context.Background(), 3*time.Second)
 		defer produceCancel()
 
 		results := s.kafkaClient.ProduceSync(produceCtx, r)
@@ -411,7 +411,7 @@ func (s *KafkaIntegrationTestSuite) TestDeserializeRecord() {
 			Timestamp: orderCreatedAt,
 		}
 
-		produceCtx, produceCancel := context.WithTimeout(context.Background(), 1*time.Second)
+		produceCtx, produceCancel := context.WithTimeout(context.Background(), 3*time.Second)
 		defer produceCancel()
 
 		results := s.kafkaClient.ProduceSync(produceCtx, r)
@@ -578,7 +578,7 @@ func (s *KafkaIntegrationTestSuite) TestDeserializeRecord() {
 			Timestamp: orderCreatedAt,
 		}
 
-		produceCtx, produceCancel := context.WithTimeout(context.Background(), 1*time.Second)
+		produceCtx, produceCancel := context.WithTimeout(context.Background(), 3*time.Second)
 		defer produceCancel()
 
 		results := s.kafkaClient.ProduceSync(produceCtx, r)
@@ -708,7 +708,7 @@ func (s *KafkaIntegrationTestSuite) TestDeserializeRecord() {
 			Topic: testTopicName,
 		}
 
-		produceCtx, produceCancel := context.WithTimeout(context.Background(), 1*time.Second)
+		produceCtx, produceCancel := context.WithTimeout(context.Background(), 3*time.Second)
 		defer produceCancel()
 
 		results := s.kafkaClient.ProduceSync(produceCtx, r)
@@ -852,7 +852,7 @@ func (s *KafkaIntegrationTestSuite) TestDeserializeRecord() {
 			Topic: testTopicName,
 		}
 
-		produceCtx, produceCancel := context.WithTimeout(context.Background(), 1*time.Second)
+		produceCtx, produceCancel := context.WithTimeout(context.Background(), 3*time.Second)
 		defer produceCancel()
 
 		results := s.kafkaClient.ProduceSync(produceCtx, r)
@@ -1074,7 +1074,7 @@ func (s *KafkaIntegrationTestSuite) TestDeserializeRecord() {
 			Timestamp: orderCreatedAt,
 		}
 
-		produceCtx, produceCancel := context.WithTimeout(context.Background(), 1*time.Second)
+		produceCtx, produceCancel := context.WithTimeout(context.Background(), 3*time.Second)
 		defer produceCancel()
 
 		results := s.kafkaClient.ProduceSync(produceCtx, r)