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

KAFKA-13618: Fix typo in BatchAccumulator (#11715) 

Co-authored-by: Kvicii <Karonazaba@gmail.com>
Reviewers: Mickael Maison <mickael.maison@gmail.com>
This commit is contained in:
Kvicii 2022-01-27 01:30:56 +08:00 committed by GitHub
parent fe72187cb1
commit dd58f81b25
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java
View File

@ -482,7 +482,7 @@ public class BatchAccumulator<T> implements Closeable {
MemoryPool pool, MemoryPool pool,
ByteBuffer initialBuffer ByteBuffer initialBuffer
) { ) {
Objects.requireNonNull(data.firstBatch(), "Exptected memory records to contain one batch"); Objects.requireNonNull(data.firstBatch(), "Expected memory records to contain one batch");
this.baseOffset = baseOffset; this.baseOffset = baseOffset;
this.records = Optional.of(records); this.records = Optional.of(records);
@ -499,7 +499,7 @@ public class BatchAccumulator<T> implements Closeable {
MemoryPool pool, MemoryPool pool,
ByteBuffer initialBuffer ByteBuffer initialBuffer
) { ) {
Objects.requireNonNull(data.firstBatch(), "Exptected memory records to contain one batch"); Objects.requireNonNull(data.firstBatch(), "Expected memory records to contain one batch");
this.baseOffset = baseOffset; this.baseOffset = baseOffset;
this.records = Optional.empty(); this.records = Optional.empty();