Skip to content

Commit 30a488c

Browse files
committed
checkstyle
1 parent 362f6b8 commit 30a488c

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
@@ -2445,8 +2445,7 @@ private void recoverProcessOpSendMsgFrom(ClientCnx cnx, MessageImpl latestMsgAtt
24452445
// called again once the new connection registers the producer with the broker.
24462446
log.info("[{}][{}] Producer epoch mismatch or the current connection is null. Skip re-sending the "
24472447
+ " {} pending messages since they will deliver using another connection.", topic,
2448-
producerName,
2449-
pendingMessages.messagesCount());
2448+
producerName, pendingMessages.messagesCount());
24502449
return;
24512450
}
24522451
final boolean stripChecksum = cnx.getRemoteEndpointProtocolVersion() < brokerChecksumSupportedVersion();

0 commit comments

Comments
 (0)