@@ -44,7 +44,7 @@ void testKafkaClientsAreDeployed(String namespace, String clientNamePrefix, int
44
44
45
45
private static Stream <Arguments > clientDeployments () {
46
46
return Stream .of (
47
- Arguments .of (ENamespaces .CLIENTS .name , "big-external-producer" , 30 ),
47
+ Arguments .of (ENamespaces .CLIENTS .name , "big-external-producer" , 3 ),
48
48
Arguments .of (ENamespaces .CLIENTS .name , "big-external-consumer" , 3 ),
49
49
Arguments .of (ENamespaces .CLIENTS .name , "big-external-streams" , 3 ),
50
50
Arguments .of (ENamespaces .CLIENTS .name , "big-internal-producer" , 3 ),
@@ -53,14 +53,14 @@ private static Stream<Arguments> clientDeployments() {
53
53
Arguments .of (ENamespaces .CLIENTS .name , "fast-external-producer" , 3 ),
54
54
Arguments .of (ENamespaces .CLIENTS .name , "fast-external-consumer" , 3 ),
55
55
Arguments .of (ENamespaces .CLIENTS .name , "fast-external-streams" , 3 ),
56
- Arguments .of (ENamespaces .CLIENTS .name , "fast-internal-producer" , 30 ),
56
+ Arguments .of (ENamespaces .CLIENTS .name , "fast-internal-producer" , 3 ),
57
57
Arguments .of (ENamespaces .CLIENTS .name , "fast-internal-consumer" , 3 ),
58
58
Arguments .of (ENamespaces .CLIENTS .name , "fast-internal-streams" , 3 ),
59
59
Arguments .of (ENamespaces .CLIENTS .name , "iot-external-producer" , 3 ),
60
60
Arguments .of (ENamespaces .CLIENTS .name , "iot-external-consumer" , 3 ),
61
61
Arguments .of (ENamespaces .CLIENTS .name , "iot-external-streams" , 3 ),
62
62
Arguments .of (ENamespaces .CLIENTS .name , "iot-internal-producer" , 3 ),
63
- Arguments .of (ENamespaces .CLIENTS .name , "iot-internal-consumer" , 30 ),
63
+ Arguments .of (ENamespaces .CLIENTS .name , "iot-internal-consumer" , 3 ),
64
64
Arguments .of (ENamespaces .CLIENTS .name , "iot-internal-streams" , 3 ),
65
65
Arguments .of (ENamespaces .CLIENTS_KRAFT .name , "horus-consumer" , 3 )
66
66
);
0 commit comments