This is an automated email from the ASF dual-hosted git repository.
mimaison pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 8c15611221e MINOR: Fix various typos in javadoc, logs and messages
(#22565)
8c15611221e is described below
commit 8c15611221e6c52e19c5023450c60936df7a1652
Author: CoderBruis <[email protected]>
AuthorDate: Tue Jul 7 20:30:05 2026 +0800
MINOR: Fix various typos in javadoc, logs and messages (#22565)
Reviewers: Ken Huang <[email protected]>, Mickael Maison
<[email protected]>
Co-authored-by: haiyang.luo <[email protected]>
---
.../main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java | 2 +-
.../apache/kafka/clients/consumer/internals/ConsumerCoordinator.java | 2 +-
.../apache/kafka/clients/producer/internals/RecordAccumulator.java | 4 ++--
.../src/main/java/org/apache/kafka/common/protocol/types/Type.java | 2 +-
core/src/main/scala/kafka/cluster/Partition.scala | 2 +-
5 files changed, 6 insertions(+), 6 deletions(-)
diff --git
a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
index 6b3af268b5f..5aac6c9a81c 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
@@ -431,7 +431,7 @@ import static
org.apache.kafka.common.utils.Utils.propsToMap;
*
* <p>
* Partitions with transactional messages will include commit or abort markers
which indicate the result of a transaction.
- * There markers are not returned to applications, yet have an offset in the
log. As a result, applications reading from
+ * These markers are not returned to applications, yet have an offset in the
log. As a result, applications reading from
* topics with transactional messages will see gaps in the consumed offsets.
These missing messages would be the transaction
* markers, and they are filtered out for consumers in both isolation levels.
Additionally, applications using
* {@code read_committed} consumers may also see gaps due to aborted
transactions, since those messages would not
diff --git
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
index 1c9c231e361..476fe8bbd2c 100644
---
a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
+++
b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
@@ -1413,7 +1413,7 @@ public final class ConsumerCoordinator extends
AbstractCoordinator {
if (ConsumerCoordinator.this.state ==
MemberState.PREPARING_REBALANCE) {
exception = new
RebalanceInProgressException("Offset commit cannot be completed since the " +
"consumer member's old generation
is fenced by its group instance id, it is possible that " +
- "this consumer has already
participated another rebalance and got a new generation");
+ "this consumer has already
participated in another rebalance and got a new generation");
} else {
exception = new
CommitFailedException();
}
diff --git
a/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
b/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
index fd1cae3d8e4..1019e276216 100644
---
a/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
+++
b/clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java
@@ -231,7 +231,7 @@ public class RecordAccumulator {
* @param partitionInfo The built-in partitioner's partition info
* @param deque The partition queue
* @param nowMs The current time, in milliseconds
- * @param cluster THe cluster metadata
+ * @param cluster The cluster metadata
* @return 'true' if partition changed and we need to get new partition
info and retry,
* 'false' otherwise
*/
@@ -511,7 +511,7 @@ public class RecordAccumulator {
}
/**
- * Split the big batch that has been rejected and reenqueue the split
batches in to the accumulator.
+ * Split the big batch that has been rejected and reenqueue the split
batches into the accumulator.
* @return the number of split batches.
*/
public int splitAndReenqueue(ProducerBatch bigBatch) {
diff --git
a/clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java
b/clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java
index b2919dc52f2..f97df06f328 100644
--- a/clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java
+++ b/clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java
@@ -287,7 +287,7 @@ public abstract class Type {
if (item instanceof Integer)
return (Integer) item;
else
- throw new SchemaException(item + " is not an a Integer
(encoding an unsigned short)");
+ throw new SchemaException(item + " is not an Integer (encoding
an unsigned short)");
}
@Override
diff --git a/core/src/main/scala/kafka/cluster/Partition.scala
b/core/src/main/scala/kafka/cluster/Partition.scala
index 49cd785355b..96bc3ddebf4 100755
--- a/core/src/main/scala/kafka/cluster/Partition.scala
+++ b/core/src/main/scala/kafka/cluster/Partition.scala
@@ -1009,7 +1009,7 @@ class Partition(val topicPartition: TopicPartition,
*/
private def maybeIncrementLeaderHW(leaderLog: UnifiedLog, currentTimeMs:
Long = time.milliseconds): Boolean = {
if (isUnderMinIsr) {
- trace(s"Not increasing HWM because partition is under min
ISR(ISR=${partitionState.isr}")
+ trace(s"Not increasing HWM because partition is under min
ISR(ISR=${partitionState.isr})")
return false
}
// maybeIncrementLeaderHW is in the hot path, the following code is
written to
