|
47 | 47 | */ |
48 | 48 | public class AckModeRecordFilteredTest { |
49 | 49 |
|
| 50 | + @SuppressWarnings("unchecked") |
50 | 51 | @Test |
51 | 52 | public void testRecordFilteredModeOnlyCommitsProcessedRecords() throws InterruptedException { |
52 | 53 | // Given: A container with RECORD_FILTERED ack mode |
@@ -103,6 +104,7 @@ public void testRecordFilteredModeOnlyCommitsProcessedRecords() throws Interrupt |
103 | 104 | verify(consumer, times(2)).commitSync(any(), any(Duration.class)); |
104 | 105 | } |
105 | 106 |
|
| 107 | + @SuppressWarnings("unchecked") |
106 | 108 | @Test |
107 | 109 | public void testRecordFilteredModeWithAllRecordsFiltered() throws InterruptedException { |
108 | 110 | // Given: All records are filtered |
@@ -150,6 +152,7 @@ public void testRecordFilteredModeWithAllRecordsFiltered() throws InterruptedExc |
150 | 152 | verify(consumer, never()).commitSync(any(), any(Duration.class)); |
151 | 153 | } |
152 | 154 |
|
| 155 | + @SuppressWarnings("unchecked") |
153 | 156 | @Test |
154 | 157 | public void testRecordFilteredModeWithMixedPartitions() throws InterruptedException { |
155 | 158 | // Given: Mixed partitions with different filtering scenarios |
@@ -212,6 +215,7 @@ public void testRecordFilteredModeWithMixedPartitions() throws InterruptedExcept |
212 | 215 | verify(consumer, times(3)).commitSync(any(), any(Duration.class)); |
213 | 216 | } |
214 | 217 |
|
| 218 | + @SuppressWarnings("unchecked") |
215 | 219 | @Test |
216 | 220 | public void testRecordFilteredModeEfficiencyGains() throws InterruptedException { |
217 | 221 | ConsumerFactory<String, String> consumerFactory = mock(ConsumerFactory.class); |
@@ -264,6 +268,7 @@ public void testRecordFilteredModeEfficiencyGains() throws InterruptedException |
264 | 268 | verify(consumer, times(1)).commitSync(any(), any(Duration.class)); |
265 | 269 | } |
266 | 270 |
|
| 271 | + @SuppressWarnings("unchecked") |
267 | 272 | @Test |
268 | 273 | public void testRecordFilteredModeDoesNotBreakNormalProcessing() throws InterruptedException { |
269 | 274 | ConsumerFactory<String, String> consumerFactory = mock(ConsumerFactory.class); |
|
0 commit comments