6969@ SuppressWarnings ("rawtypes" )
7070@ ExtendWith (MockitoExtension .class )
7171@ MockitoSettings (strictness = Strictness .STRICT_STUBS )
72- public class ChangeLoggingKeyValueBytesStoreTest {
72+ class ChangeLoggingKeyValueBytesStoreTest {
7373
7474 private final MockRecordCollector collector = new MockRecordCollector ();
7575 private final InMemoryKeyValueStore inner = new InMemoryKeyValueStore ("kv" );
@@ -111,7 +111,7 @@ public void after() {
111111 }
112112
113113 @ Test
114- public void shouldDelegateInit () {
114+ void shouldDelegateInit () {
115115 final InternalMockProcessorContext context = mockContext ();
116116 final KeyValueStore <Bytes , byte []> innerMock = mock (InMemoryKeyValueStore .class );
117117 final StateStore outer = new ChangeLoggingKeyValueBytesStore (innerMock );
@@ -120,7 +120,7 @@ public void shouldDelegateInit() {
120120 }
121121
122122 @ Test
123- public void shouldWriteKeyValueBytesToInnerStoreOnPut () {
123+ void shouldWriteKeyValueBytesToInnerStoreOnPut () {
124124 store .put (hi , there );
125125 assertThat (inner .get (hi ), equalTo (there ));
126126 assertThat (collector .collected ().size (), equalTo (1 ));
@@ -129,7 +129,7 @@ public void shouldWriteKeyValueBytesToInnerStoreOnPut() {
129129 }
130130
131131 @ Test
132- public void shouldWriteAllKeyValueToInnerStoreOnPutAll () {
132+ void shouldWriteAllKeyValueToInnerStoreOnPutAll () {
133133 store .putAll (Arrays .asList (KeyValue .pair (hi , there ),
134134 KeyValue .pair (hello , world )));
135135 assertThat (inner .get (hi ), equalTo (there ));
@@ -143,21 +143,21 @@ public void shouldWriteAllKeyValueToInnerStoreOnPutAll() {
143143 }
144144
145145 @ Test
146- public void shouldPropagateDelete () {
146+ void shouldPropagateDelete () {
147147 store .put (hi , there );
148148 store .delete (hi );
149149 assertThat (inner .approximateNumEntries (), equalTo (0L ));
150150 assertThat (inner .get (hi ), nullValue ());
151151 }
152152
153153 @ Test
154- public void shouldReturnOldValueOnDelete () {
154+ void shouldReturnOldValueOnDelete () {
155155 store .put (hi , there );
156156 assertThat (store .delete (hi ), equalTo (there ));
157157 }
158158
159159 @ Test
160- public void shouldLogKeyNullOnDelete () {
160+ void shouldLogKeyNullOnDelete () {
161161 store .put (hi , there );
162162 assertThat (store .delete (hi ), equalTo (there ));
163163
@@ -169,20 +169,20 @@ public void shouldLogKeyNullOnDelete() {
169169 }
170170
171171 @ Test
172- public void shouldWriteToInnerOnPutIfAbsentNoPreviousValue () {
172+ void shouldWriteToInnerOnPutIfAbsentNoPreviousValue () {
173173 store .putIfAbsent (hi , there );
174174 assertThat (inner .get (hi ), equalTo (there ));
175175 }
176176
177177 @ Test
178- public void shouldNotWriteToInnerOnPutIfAbsentWhenValueForKeyExists () {
178+ void shouldNotWriteToInnerOnPutIfAbsentWhenValueForKeyExists () {
179179 store .put (hi , there );
180180 store .putIfAbsent (hi , world );
181181 assertThat (inner .get (hi ), equalTo (there ));
182182 }
183183
184184 @ Test
185- public void shouldWriteToChangelogOnPutIfAbsentWhenNoPreviousValue () {
185+ void shouldWriteToChangelogOnPutIfAbsentWhenNoPreviousValue () {
186186 store .putIfAbsent (hi , there );
187187
188188 assertThat (collector .collected ().size (), equalTo (1 ));
@@ -191,7 +191,7 @@ public void shouldWriteToChangelogOnPutIfAbsentWhenNoPreviousValue() {
191191 }
192192
193193 @ Test
194- public void shouldNotWriteToChangeLogOnPutIfAbsentWhenValueForKeyExists () {
194+ void shouldNotWriteToChangeLogOnPutIfAbsentWhenValueForKeyExists () {
195195 store .put (hi , there );
196196 store .putIfAbsent (hi , world );
197197
@@ -201,24 +201,24 @@ public void shouldNotWriteToChangeLogOnPutIfAbsentWhenValueForKeyExists() {
201201 }
202202
203203 @ Test
204- public void shouldReturnCurrentValueOnPutIfAbsent () {
204+ void shouldReturnCurrentValueOnPutIfAbsent () {
205205 store .put (hi , there );
206206 assertThat (store .putIfAbsent (hi , world ), equalTo (there ));
207207 }
208208
209209 @ Test
210- public void shouldReturnNullOnPutIfAbsentWhenNoPreviousValue () {
210+ void shouldReturnNullOnPutIfAbsentWhenNoPreviousValue () {
211211 assertThat (store .putIfAbsent (hi , there ), is (nullValue ()));
212212 }
213213
214214 @ Test
215- public void shouldReturnValueOnGetWhenExists () {
215+ void shouldReturnValueOnGetWhenExists () {
216216 store .put (hello , world );
217217 assertThat (store .get (hello ), equalTo (world ));
218218 }
219219
220220 @ Test
221- public void shouldGetRecordsWithPrefixKey () {
221+ void shouldGetRecordsWithPrefixKey () {
222222 store .put (hi , there );
223223 store .put (Bytes .increment (hi ), world );
224224
@@ -241,12 +241,12 @@ public void shouldGetRecordsWithPrefixKey() {
241241 }
242242
243243 @ Test
244- public void shouldReturnNullOnGetWhenDoesntExist () {
244+ void shouldReturnNullOnGetWhenDoesntExist () {
245245 assertThat (store .get (hello ), is (nullValue ()));
246246 }
247247
248248 @ Test
249- public void shouldLogPositionOnPut () {
249+ void shouldLogPositionOnPut () {
250250 context .setRecordContext (new ProcessorRecordContext (-1 , INPUT_OFFSET , INPUT_PARTITION , INPUT_TOPIC_NAME , new RecordHeaders ()));
251251 context .setTime (1L );
252252 store .put (hi , there );
0 commit comments