@@ -61,10 +61,10 @@ public int sendStringMessagesPlain(long timeoutMs, String topicName, int message
61
61
properties .setProperty (CommonClientConfigs .SECURITY_PROTOCOL_CONFIG , SecurityProtocol .PLAINTEXT .name );
62
62
63
63
try (Producer plainProducer = new Producer .ProducerBuilder (resultPromise , msgCntPredicate , topicName , message , partition , timestamp )
64
- .withProperties (properties )
65
- .withHeaders (headers )
66
- .withNullKeyRecord (withNullKeyRecord )
67
- .build ()) {
64
+ .withProperties (properties )
65
+ .withHeaders (headers )
66
+ .withNullKeyRecord (withNullKeyRecord )
67
+ .build ()) {
68
68
69
69
plainProducer .getVertx ().deployVerticle (plainProducer );
70
70
@@ -98,12 +98,12 @@ public int sendStringMessagesPlain(String topicName, int messageCount) {
98
98
*/
99
99
public int sendStringMessagesPlain (String topicName , String message , int messageCount , int partition ) {
100
100
return sendStringMessagesPlain (Duration .ofMinutes (2 ).toMillis (), topicName , messageCount ,
101
- List .of (), message , partition , null , true );
101
+ List .of (), message , partition , null , true );
102
102
}
103
103
104
104
public int sendStringMessagesPlain (String topicName , String message , int messageCount , int partition , boolean withNullKeyRecord ) {
105
105
return sendStringMessagesPlain (Duration .ofMinutes (2 ).toMillis (), topicName , messageCount ,
106
- List .of (), message , partition , null , withNullKeyRecord );
106
+ List .of (), message , partition , null , withNullKeyRecord );
107
107
}
108
108
109
109
/**
0 commit comments