|
50 | 50 | * @author Chaedong Im |
51 | 51 | * @see AckModeRecordWithFilteringTest |
52 | 52 | */ |
53 | | -public class AckModeRecordFilteredTest { |
| 53 | +class AckModeRecordFilteredTest { |
54 | 54 |
|
55 | 55 | @SuppressWarnings({"unchecked", "deprecation"}) |
56 | 56 | @Test |
57 | | - public void testRecordFilteredModeOnlyCommitsProcessedRecords() throws InterruptedException { |
| 57 | + void testRecordFilteredModeOnlyCommitsProcessedRecords() throws InterruptedException { |
58 | 58 | // Given: A container with RECORD_FILTERED ack mode |
59 | 59 | ConsumerFactory<String, String> consumerFactory = mock(ConsumerFactory.class); |
60 | 60 | Consumer<String, String> consumer = mock(Consumer.class); |
@@ -111,7 +111,7 @@ public void testRecordFilteredModeOnlyCommitsProcessedRecords() throws Interrupt |
111 | 111 |
|
112 | 112 | @SuppressWarnings({"unchecked", "deprecation"}) |
113 | 113 | @Test |
114 | | - public void testRecordFilteredModeWithAllRecordsFiltered() throws InterruptedException { |
| 114 | + void testRecordFilteredModeWithAllRecordsFiltered() throws InterruptedException { |
115 | 115 | // Given: All records are filtered |
116 | 116 | ConsumerFactory<String, String> consumerFactory = mock(ConsumerFactory.class); |
117 | 117 | Consumer<String, String> consumer = mock(Consumer.class); |
@@ -159,7 +159,7 @@ public void testRecordFilteredModeWithAllRecordsFiltered() throws InterruptedExc |
159 | 159 |
|
160 | 160 | @SuppressWarnings({"unchecked", "deprecation"}) |
161 | 161 | @Test |
162 | | - public void testRecordFilteredModeWithMixedPartitions() throws InterruptedException { |
| 162 | + void testRecordFilteredModeWithMixedPartitions() throws InterruptedException { |
163 | 163 | // Given: Mixed partitions with different filtering scenarios |
164 | 164 | ConsumerFactory<String, String> consumerFactory = mock(ConsumerFactory.class); |
165 | 165 | Consumer<String, String> consumer = mock(Consumer.class); |
@@ -222,7 +222,7 @@ public void testRecordFilteredModeWithMixedPartitions() throws InterruptedExcept |
222 | 222 |
|
223 | 223 | @SuppressWarnings({"unchecked", "deprecation"}) |
224 | 224 | @Test |
225 | | - public void testRecordFilteredModeEfficiencyGains() throws InterruptedException { |
| 225 | + void testRecordFilteredModeEfficiencyGains() throws InterruptedException { |
226 | 226 | ConsumerFactory<String, String> consumerFactory = mock(ConsumerFactory.class); |
227 | 227 | Consumer<String, String> consumer = mock(Consumer.class); |
228 | 228 | given(consumerFactory.createConsumer(any(), any(), any(), any())).willReturn(consumer); |
@@ -275,7 +275,7 @@ public void testRecordFilteredModeEfficiencyGains() throws InterruptedException |
275 | 275 |
|
276 | 276 | @SuppressWarnings({"unchecked", "deprecation"}) |
277 | 277 | @Test |
278 | | - public void testRecordFilteredModeDoesNotBreakNormalProcessing() throws InterruptedException { |
| 278 | + void testRecordFilteredModeDoesNotBreakNormalProcessing() throws InterruptedException { |
279 | 279 | ConsumerFactory<String, String> consumerFactory = mock(ConsumerFactory.class); |
280 | 280 | Consumer<String, String> consumer = mock(Consumer.class); |
281 | 281 | given(consumerFactory.createConsumer(any(), any(), any(), any())).willReturn(consumer); |
|
0 commit comments