From 8a04e0eca442a5326b98c36be451b71a029f0a9f Mon Sep 17 00:00:00 2001
From: "Matthias J. Sax" <matthias@confluent.io>
Date: Thu, 16 Jan 2025 09:54:52 -0800
Subject: [PATCH] MINOR: change warning suppression in
 RocksDBTimeOrderedKeyValueBufferTest

---
 .../internals/RocksDBTimeOrderedKeyValueBufferTest.java     | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBufferTest.java b/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBufferTest.java
index 9a92df5533632..69e7d31e31b4b 100644
--- a/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBufferTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBufferTest.java
@@ -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 @@ private boolean pipeRecord(final String key, final String value, final long time
         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 void shouldAddAndEvictRecord() {
         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 void shouldAddAndEvictRecordTwiceWithNonZeroGrace() {
         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 void shouldAddRecordsTwiceAndEvictRecordsOnce() {
         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 void shouldDropLateRecordsWithNonZeroGrace() {
         assertNumSizeAndTimestamp(buffer, 2, 1, 84);
     }
 
+    @SuppressWarnings({"rawtypes", "unchecked"})
     @Test
     public void shouldHandleCollidingKeys() {
         when(serdeGetter.keySerde()).thenReturn((Serde) new Serdes.StringSerde());