root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: fix typos for server common (#13887) 

Reviewers: Manyanda Chitimbo <manyanda.chitimbo@gmail.com>, Divij Vaidya <diviv@amazon.com>
This commit is contained in:
minjian.cai 2023-06-21 04:56:01 +08:00 committed by GitHub
parent 3d97743c67
commit af678a563d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java
View File

@ -99,7 +99,7 @@ public enum MetadataVersion {
IBP_2_1_IV2(-1, "2.1", "IV2"), IBP_2_1_IV2(-1, "2.1", "IV2"),
// Introduced broker generation (KIP-380), and // 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"), IBP_2_2_IV0(-1, "2.2", "IV0"),
// New error code for ListOffsets when a new leader is lagging behind former HW (KIP-207) // New error code for ListOffsets when a new leader is lagging behind former HW (KIP-207)

16
server-common/src/test/java/org/apache/kafka/queue/KafkaEventQueueTest.java
View File

@ -224,9 +224,9 @@ public class KafkaEventQueueTest {
} }
@Test @Test
public void testRejectedExecutionExecption() throws Exception { public void testRejectedExecutionException() throws Exception {
KafkaEventQueue queue = new KafkaEventQueue(Time.SYSTEM, new LogContext(), KafkaEventQueue queue = new KafkaEventQueue(Time.SYSTEM, new LogContext(),
"testRejectedExecutionExecption"); "testRejectedExecutionException");
queue.close(); queue.close();
CompletableFuture<Void> future = new CompletableFuture<>(); CompletableFuture<Void> future = new CompletableFuture<>();
queue.append(new EventQueue.Event() { queue.append(new EventQueue.Event() {
@ -305,13 +305,13 @@ public class KafkaEventQueueTest {
queue.close(); queue.close();
} }
private static class InterruptableEvent implements EventQueue.Event { private static class InterruptibleEvent implements EventQueue.Event {
private final CompletableFuture<Void> runFuture; private final CompletableFuture<Void> runFuture;
private final CompletableFuture<Thread> queueThread; private final CompletableFuture<Thread> queueThread;
private final AtomicInteger numCallsToRun; private final AtomicInteger numCallsToRun;
private final AtomicInteger numInterruptedExceptionsSeen; private final AtomicInteger numInterruptedExceptionsSeen;
InterruptableEvent( InterruptibleEvent(
CompletableFuture<Thread> queueThread, CompletableFuture<Thread> queueThread,
AtomicInteger numCallsToRun, AtomicInteger numCallsToRun,
AtomicInteger numInterruptedExceptionsSeen AtomicInteger numInterruptedExceptionsSeen
@ -345,10 +345,10 @@ public class KafkaEventQueueTest {
CompletableFuture<Thread> queueThread = new CompletableFuture<>(); CompletableFuture<Thread> queueThread = new CompletableFuture<>();
AtomicInteger numCallsToRun = new AtomicInteger(0); AtomicInteger numCallsToRun = new AtomicInteger(0);
AtomicInteger numInterruptedExceptionsSeen = new AtomicInteger(0); AtomicInteger numInterruptedExceptionsSeen = new AtomicInteger(0);
queue.append(new InterruptableEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen)); queue.append(new InterruptibleEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen));
queue.append(new InterruptableEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen)); queue.append(new InterruptibleEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen));
queue.append(new InterruptableEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen)); queue.append(new InterruptibleEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen));
queue.append(new InterruptableEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen)); queue.append(new InterruptibleEvent(queueThread, numCallsToRun, numInterruptedExceptionsSeen));
queueThread.get().interrupt(); queueThread.get().interrupt();
TestUtils.retryOnExceptionWithTimeout(30000, TestUtils.retryOnExceptionWithTimeout(30000,
() -> assertEquals(1, numCallsToRun.get())); () -> assertEquals(1, numCallsToRun.get()));

2
server-common/src/test/java/org/apache/kafka/timeline/BaseHashTableTest.java
View File

@ -85,7 +85,7 @@ public class BaseHashTableTest {
} }
@Test @Test
public void testHashCollisons() { public void testHashCollisions() {
Foo one = new Foo(); Foo one = new Foo();
Foo two = new Foo(); Foo two = new Foo();
Foo three = new Foo(); Foo three = new Foo();