joshua2519 commented on code in PR #21429:
URL: https://github.com/apache/kafka/pull/21429#discussion_r2783074135
##########
clients/src/main/java/org/apache/kafka/clients/consumer/CommitFailedException.java:
##########
@@ -28,16 +28,24 @@ public class CommitFailedException extends KafkaException {
private static final long serialVersionUID = 1L;
+ /**
+ * Constructs a new CommitFailedException with the specified detail
message.
+ *
+ * @param message The error message
+ */
public CommitFailedException(final String message) {
super(message);
}
+ /**
+ * Constructs a new CommitFailedException with a default message
explaining the cause of the commit failure.
+ */
public CommitFailedException() {
super("Commit cannot be completed since the group has already " +
- "rebalanced and assigned the partitions to another member.
This means that the time " +
- "between subsequent calls to poll() was longer than the
configured max.poll.interval.ms, " +
- "which typically implies that the poll loop is spending too
much time message processing. " +
- "You can address this either by increasing
max.poll.interval.ms or by reducing the maximum " +
- "size of batches returned in poll() with max.poll.records.");
+ "rebalanced and assigned the partitions to another member. This
means that the time " +
+ "between subsequent calls to poll() was longer than the configured
max.poll.interval.ms, " +
+ "which typically implies that the poll loop is spending too much
time message processing. " +
+ "You can address this either by increasing max.poll.interval.ms or
by reducing the maximum " +
+ "size of batches returned in poll() with max.poll.records.");
}
Review Comment:
Nit: It looks like the indentation here changed unintentionally. Could you
revert this to match the original formatting?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
