You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by di...@apache.org on 2023/06/20 20:56:08 UTC
[kafka] branch trunk updated: MINOR: fix typos for server common (#13887)
This is an automated email from the ASF dual-hosted git repository.
divijv 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 af678a563d9 MINOR: fix typos for server common (#13887)
af678a563d9 is described below
commit af678a563d9b89e8bd87f77d400b693bd47829c4
Author: minjian.cai <cm...@163.com>
AuthorDate: Wed Jun 21 04:56:01 2023 +0800
MINOR: fix typos for server common (#13887)
Reviewers: Manyanda Chitimbo <ma...@gmail.com>, Divij Vaidya <di...@amazon.com>
---
.../org/apache/kafka/server/common/MetadataVersion.java | 2 +-
.../java/org/apache/kafka/queue/KafkaEventQueueTest.java | 16 ++++++++--------
.../org/apache/kafka/timeline/BaseHashTableTest.java | 2 +-
3 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java b/server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java
index 29bfd29f0e6..2637aef7016 100644
--- a/server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java
+++ b/server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java
@@ -99,7 +99,7 @@ public enum MetadataVersion {
IBP_2_1_IV2(-1, "2.1", "IV2"),
// Introduced broker generation (KIP-380), and
- // LeaderAdnIsrRequest V2, UpdateMetadataRequest V5, StopReplicaRequest V1
+ // LeaderAndIsrRequest V2, UpdateMetadataRequest V5, StopReplicaRequest V1
IBP_2_2_IV0(-1, "2.2", "IV0"),
// New error code for ListOffsets when a new leader is lagging behind former HW (KIP-207)
diff --git a/server-common/src/test/java/org/apache/kafka/queue/KafkaEventQueueTest.java b/server-common/src/test/java/org/apache/kafka/queue/KafkaEventQueueTest.java
index 3c0aa63661e..6ac0816633c 100644
--- a/server-common/src/test/java/org/apache/kafka/queue/KafkaEventQueueTest.java
+++ b/server-common/src/test/java/org/apache/kafka/queue/KafkaEventQueueTest.java
@@ -224,9 +224,9 @@ public class KafkaEventQueueTest {
}
@Test
- public void testRejectedExecutionExecption() throws Exception {
+ public void testRejectedExecutionException() throws Exception {
KafkaEventQueue queue = new KafkaEventQueue(Time.SYSTEM, new LogContext(),
- "testRejectedExecutionExecption");
+ "testRejectedExecutionException");
queue.close();
CompletableFuture<Void> future = new CompletableFuture<>();
queue.append(new EventQueue.Event() {
@@ -305,13 +305,13 @@ public class KafkaEventQueueTest {
queue.close();
}
- private static class InterruptableEvent implements EventQueue.Event {
+ private static class InterruptibleEvent implements EventQueue.Event {
private final CompletableFuture<Void> runFuture;
private final CompletableFuture<Thread> queueThread;
private final AtomicInteger numCallsToRun;
private final AtomicInteger numInterruptedExceptionsSeen;
- InterruptableEvent(
+ InterruptibleEvent(
CompletableFuture<Thread> queueThread,
AtomicInteger numCallsToRun,
AtomicInteger numInterruptedExceptionsSeen
@@ -345,10 +345,10 @@ public class KafkaEventQueueTest {
CompletableFuture<Thread> queueThread = new CompletableFuture<>();
AtomicInteger numCallsToRun = new AtomicInteger(0);
AtomicInteger numInterruptedExceptionsSeen = new AtomicInteger(0);
- queue.append(new InterruptableEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen));
- queue.append(new InterruptableEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen));
- queue.append(new InterruptableEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen));
- queue.append(new InterruptableEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen));
+ queue.append(new InterruptibleEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen));
+ queue.append(new InterruptibleEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen));
+ queue.append(new InterruptibleEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen));
+ queue.append(new InterruptibleEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen));
queueThread.get().interrupt();
TestUtils.retryOnExceptionWithTimeout(30000,
() -> assertEquals(1, numCallsToRun.get()));
diff --git a/server-common/src/test/java/org/apache/kafka/timeline/BaseHashTableTest.java b/server-common/src/test/java/org/apache/kafka/timeline/BaseHashTableTest.java
index 8d70ae74198..1da32d4b3d9 100644
--- a/server-common/src/test/java/org/apache/kafka/timeline/BaseHashTableTest.java
+++ b/server-common/src/test/java/org/apache/kafka/timeline/BaseHashTableTest.java
@@ -85,7 +85,7 @@ public class BaseHashTableTest {
}
@Test
- public void testHashCollisons() {
+ public void testHashCollisions() {
Foo one = new Foo();
Foo two = new Foo();
Foo three = new Foo();