fix checkstyle test

apache · Sep 20, 2024 · fe2ad32 · fe2ad32
1 parent 501be6c
commit fe2ad32
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSIntegrationTest.java b/...ams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSIntegrationTest.java
@@ -337,13 +337,13 @@ private KafkaStreams buildWithDeduplicationTopology(final String stateDirPath) {
                     private KeyValueStore<Integer, Integer> store;
 
                     @Override
-                    public void init(ProcessorContext<Integer, Integer> context) {
+                    public void init(final ProcessorContext<Integer, Integer> context) {
                         this.context = context;
                         store = context.getStateStore(storeName);
                     }
 
                     @Override
-                    public void process(Record<Integer, Integer> record) {
+                    public void process(final Record<Integer, Integer> record) {
                         final Integer key = record.key();
                         final Integer value = record.value();