Skip to content

Commit af91444

Browse files
committed
checkstyle
1 parent 542a7bb commit af91444

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

Diff for: pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -2455,8 +2455,7 @@ private void recoverProcessOpSendMsgFrom(ClientCnx cnx, MessageImpl latestMsgAtt
24552455
// called again once the new connection registers the producer with the broker.
24562456
log.info("[{}][{}] Producer epoch mismatch or the current connection is null. Skip re-sending the "
24572457
+ " {} pending messages since they will deliver using another connection.", topic,
2458-
producerName,
2459-
pendingMessages.messagesCount());
2458+
producerName, pendingMessages.messagesCount());
24602459
return;
24612460
}
24622461
final boolean stripChecksum = cnx.getRemoteEndpointProtocolVersion() < brokerChecksumSupportedVersion();

0 commit comments

Comments
 (0)