Backend integration tests improvements (#791)

* backend: remove container names in kafka connect integration tests

* backend: increase produce timeouts in deserializer integration tests

Author: Bojan

backend/pkg/api/handle_kafka_connect_integration_test.go

@@ -258,8 +258,7 @@ func runConnect(network string, bootstrapServers []string) (testcontainers.Conta
 
 	return testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
 		ContainerRequest: testcontainers.ContainerRequest{
-			Name:         "redpanda-connect",
-			Image:        "docker.cloudsmith.io/redpanda/connectors-unsupported/connectors:v1.0.0-e80470f",
+			Image:        "docker.cloudsmith.io/redpanda/connectors-unsupported/connectors:v1.0.0-3d7ab4d",
 			ExposedPorts: []string{strconv.FormatInt(int64(nat.Port("8083/tcp").Int()), 10)},
 			Env: map[string]string{
 				"CONNECT_CONFIGURATION":     testConnectConfig,
@@ -293,7 +292,6 @@ func runRedpandaForConnect(ctx context.Context, network string, plaintextKafkaPo
 
 	req := testcontainers.GenericContainerRequest{
 		ContainerRequest: testcontainers.ContainerRequest{
-			Name:           "local-redpanda",
 			Hostname:       "redpanda",
 			Networks:       []string{network},
 			NetworkAliases: map[string][]string{network: {"redpanda", "local-redpanda"}},
@@ -361,7 +359,6 @@ func runRedpandaForConnect(ctx context.Context, network string, plaintextKafkaPo
 func runHTTPBin(ctx context.Context, network string) (testcontainers.Container, error) {
 	req := testcontainers.GenericContainerRequest{
 		ContainerRequest: testcontainers.ContainerRequest{
-			Name:           "local-httpbin",
 			Hostname:       "httpbin",
 			Networks:       []string{network},
 			NetworkAliases: map[string][]string{network: {"httpbin", "local-httpbin"}},

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)