Skip to content

Commit

Permalink
SuppressWarnings checkstyle's ParameterNumber rule
Browse files Browse the repository at this point in the history
Signed-off-by: Antonio Pedro <[email protected]>
  • Loading branch information
antonio-pedro99 committed Jul 22, 2024
1 parent 170db87 commit 3b7dbb5
Showing 1 changed file with 6 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,7 @@ public BasicKafkaClient(String bootstrapServer) {
* @param withNullKeyRecord boolean, which allowing sending messages with NULL key
* @return sent message count
*/
@SuppressWarnings("checkstyle:ParameterNumber")
public int sendStringMessagesPlain(long timeoutMs, String topicName, int messageCount, List<KafkaHeader> headers,
String message, int partition, Long timestamp, boolean withNullKeyRecord) {
CompletableFuture<Integer> resultPromise = new CompletableFuture<>();
Expand Down Expand Up @@ -118,6 +119,7 @@ public int sendStringMessagesPlain(String topicName, String message, int message
* @param withNullKeyRecord boolean, which allowing sending messages with NULL key
* @return sent message count
*/
@SuppressWarnings("checkstyle:ParameterNumber")
public int sendJsonMessagesPlain(long timeoutMs, String topicName, int messageCount, List<KafkaHeader> headers,
String message, int partition, Long timestamp, boolean withNullKeyRecord) {
CompletableFuture<Integer> resultPromise = new CompletableFuture<>();
Expand Down Expand Up @@ -170,7 +172,7 @@ public int sendJsonMessagesPlain(String topicName, int messageCount, String mess
*/
public int sendJsonMessagesPlain(String topicName, int messageCount, String message, int partition, boolean withNullKeyRecord) {
return sendJsonMessagesPlain(Duration.ofMinutes(2).toMillis(), topicName, messageCount, List.of(),
message, partition,null, withNullKeyRecord);
message, partition, null, withNullKeyRecord);
}

/**
Expand All @@ -185,7 +187,7 @@ public int sendJsonMessagesPlain(String topicName, int messageCount, String mess
*/
public int sendJsonMessagesPlain(String topicName, int messageCount, List<KafkaHeader> headers, String message,
boolean withNullKeyRecord) {
return sendJsonMessagesPlain(Duration.ofMinutes(2).toMillis(), topicName, messageCount, headers, message, 0,null, withNullKeyRecord);
return sendJsonMessagesPlain(Duration.ofMinutes(2).toMillis(), topicName, messageCount, headers, message, 0, null, withNullKeyRecord);
}

/**
Expand All @@ -199,7 +201,7 @@ public int sendJsonMessagesPlain(String topicName, int messageCount, List<KafkaH
*/
public int sendJsonMessagesPlain(String topicName, int messageCount, String message, int partition) {
return sendJsonMessagesPlain(Duration.ofMinutes(2).toMillis(), topicName, messageCount, List.of(),
message, partition,null, false);
message, partition, null, false);
}

/**
Expand All @@ -212,7 +214,7 @@ public int sendJsonMessagesPlain(String topicName, int messageCount, String mess
*/
public int sendJsonMessagesPlain(String topicName, int messageCount, String message) {
return sendJsonMessagesPlain(Duration.ofMinutes(2).toMillis(), topicName, messageCount, List.of(),
message, 0, null,false);
message, 0, null, false);
}

/**
Expand Down

0 comments on commit 3b7dbb5

Please sign in to comment.