@@ -100,8 +100,6 @@ void testManualTriggeringRollingUpdate() {
100
100
final KafkaClients continuousClients = ClientUtils .getContinuousPlainClientBuilder (testStorage )
101
101
.withMessageCount (continuousClientsMessageCount )
102
102
.withAdditionalConfig (producerAdditionConfiguration )
103
- // TODO: needed because of bug in test-clients - https://github.com/strimzi/test-clients/issues/119
104
- .withMessagesPerTransaction ("1" )
105
103
.build ();
106
104
107
105
resourceManager .createResourceWithWait (continuousClients .producerStrimzi (), continuousClients .consumerStrimzi ());
@@ -364,8 +362,6 @@ void testAddingAndRemovingJbodVolumes() {
364
362
KafkaClients kafkaBasicClientJob = ClientUtils .getContinuousPlainClientBuilder (testStorage )
365
363
.withMessageCount (continuousClientsMessageCount )
366
364
.withAdditionalConfig (producerAdditionConfiguration )
367
- // TODO: needed because of bug in test-clients - https://github.com/strimzi/test-clients/issues/119
368
- .withMessagesPerTransaction ("1" )
369
365
.build ();
370
366
371
367
resourceManager .createResourceWithWait (kafkaBasicClientJob .producerStrimzi (), kafkaBasicClientJob .consumerStrimzi ());
@@ -507,8 +503,6 @@ void testJbodMetadataLogRelocation() {
507
503
KafkaClients kafkaBasicClientJob = ClientUtils .getContinuousPlainClientBuilder (testStorage )
508
504
.withMessageCount (continuousClientsMessageCount )
509
505
.withAdditionalConfig (producerAdditionConfiguration )
510
- // TODO: needed because of bug in test-clients - https://github.com/strimzi/test-clients/issues/119
511
- .withMessagesPerTransaction ("1" )
512
506
.build ();
513
507
514
508
resourceManager .createResourceWithWait (kafkaBasicClientJob .producerStrimzi (), kafkaBasicClientJob .consumerStrimzi ());
0 commit comments