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

MINOR: change warning suppression in RocksDBTimeOrderedKeyValueBufferTest (#18580) 

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>, Mickael Maison <mickael.maison@gmail.com>
This commit is contained in:
Matthias J. Sax 2025-01-16 12:59:01 -08:00 committed by GitHub
parent 0727f9be63
commit 07c860b730
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBufferTest.java
View File

@ -59,7 +59,6 @@ public class RocksDBTimeOrderedKeyValueBufferTest {
public Sensor sensor;
public long offset;
@SuppressWarnings({"rawtypes", "unchecked"})
@BeforeEach
public void setUp() {
final Metrics metrics = new Metrics();
@ -82,6 +81,7 @@ public class RocksDBTimeOrderedKeyValueBufferTest {
return buffer.put(time, record, context.recordContext());
}
@SuppressWarnings({"rawtypes", "unchecked"})
@Test
public void shouldReturnIfRecordWasAdded() {
when(serdeGetter.keySerde()).thenReturn((Serde) new Serdes.StringSerde());
@ -112,6 +112,7 @@ public class RocksDBTimeOrderedKeyValueBufferTest {
assertThat(count.get(), equalTo(1));
}
@SuppressWarnings({"rawtypes", "unchecked"})
@Test
public void shouldAddAndEvictRecordTwice() {
when(serdeGetter.keySerde()).thenReturn((Serde) new Serdes.StringSerde());
@ -144,6 +145,7 @@ public class RocksDBTimeOrderedKeyValueBufferTest {
assertThat(count.get(), equalTo(1));
}
@SuppressWarnings({"rawtypes", "unchecked"})
@Test
public void shouldAddRecordsTwiceAndEvictRecordsOnce() {
when(serdeGetter.keySerde()).thenReturn((Serde) new Serdes.StringSerde());
@ -158,6 +160,7 @@ public class RocksDBTimeOrderedKeyValueBufferTest {
assertThat(count.get(), equalTo(2));
}
@SuppressWarnings({"rawtypes", "unchecked"})
@Test
public void shouldDropLateRecords() {
when(serdeGetter.keySerde()).thenReturn((Serde) new Serdes.StringSerde());
@ -180,6 +183,7 @@ public class RocksDBTimeOrderedKeyValueBufferTest {
assertNumSizeAndTimestamp(buffer, 2, 1, 84);
}
@SuppressWarnings({"rawtypes", "unchecked"})
@Test
public void shouldHandleCollidingKeys() {
when(serdeGetter.keySerde()).thenReturn((Serde) new Serdes.StringSerde());