Skip to content

Commit 03e930a

Browse files
committed
Fix typos again
1 parent f540517 commit 03e930a

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBuffer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -243,7 +243,7 @@ public void evictWhile(final Supplier<Boolean> predicate, final Consumer<Evictio
243243
minTimestamp = bufferValue.context().timestamp();
244244
minValid = true;
245245

246-
final V value = valueSerde.deserializer().deserialize(topic, iternalContext.headers(), bufferValue.newValue());
246+
final V value = valueSerde.deserializer().deserialize(topic, internalContext.headers(), bufferValue.newValue());
247247

248248
callback.accept(new Eviction<>(key, value, bufferValue.context()));
249249

@@ -346,7 +346,7 @@ private void logValue(final Bytes key, final BufferKey bufferKey, final BufferVa
346346
}
347347

348348
private void logTombstone(final Bytes key) {
349-
((RecordCollector.Supplier) iternalContext).recordCollector().send(
349+
((RecordCollector.Supplier) internalContext).recordCollector().send(
350350
changelogTopic,
351351
key,
352352
null,

0 commit comments

Comments
 (0)