Fix naming conventions

.github/workflows/on_pull_request.yml → .github/workflows/pull_request.yml

@@ -2,7 +2,8 @@ name: Pull request
 
 on:
   pull_request:
-    branches: [ "main" ]
+    branches:
+      - "main"
 
 jobs:
   build:

.github/workflows/continuous_integration.yml → .github/workflows/push_main.yml

@@ -2,7 +2,8 @@ name: Continuous integration
 
 on:
   push:
-    branches: [ "main" ]
+    branches:
+      - "main"
 
 jobs:
   build:

kafka-streams-quickstarts/kafka-streams-exception-handler-processing/src/main/java/io/github/loicgreffier/streams/exception/handler/processing/app/processor/ErrorProcessor.java

@@ -7,8 +7,16 @@
 import org.apache.kafka.streams.processor.api.FixedKeyProcessorContext;
 import org.apache.kafka.streams.processor.api.FixedKeyRecord;
 
+/**
+ * This class represents a processor that throws an exception during processing and punctuation.
+ */
 public class ErrorProcessor extends ContextualFixedKeyProcessor<String, KafkaPerson, KafkaPerson> {
 
+    /**
+     * Initialize the processor.
+     *
+     * @param context the processor context.
+     */
     @Override
     public void init(FixedKeyProcessorContext<String, KafkaPerson> context) {
         super.init(context);
@@ -20,11 +28,16 @@ public void init(FixedKeyProcessorContext<String, KafkaPerson> context) {
         );
     }
 
+    /**
+     * Process the record by throwing an exception if the first name or last name is null.
+     *
+     * @param message the record to process
+     */
     @Override
-    public void process(FixedKeyRecord<String, KafkaPerson> fixedKeyRecord) {
-        if (fixedKeyRecord.value().getFirstName() == null || fixedKeyRecord.value().getLastName() == null) {
+    public void process(FixedKeyRecord<String, KafkaPerson> message) {
+        if (message.value().getFirstName() == null || message.value().getLastName() == null) {
             throw new IllegalArgumentException("First name and last name must not be null");
         }
-        context().forward(fixedKeyRecord);
+        context().forward(message);
     }
 }

kafka-streams-quickstarts/kafka-streams-process-values/src/main/java/io/github/loicgreffier/streams/processvalues/app/processor/PersonMetadataFixedKeyProcessor.java

@@ -20,21 +20,21 @@ public class PersonMetadataFixedKeyProcessor
      * Process the message by adding metadata to the message.
      * The message is then forwarded.
      *
-     * @param fixedKeyRecord the message to process.
+     * @param message the message to process.
      */
     @Override
-    public void process(FixedKeyRecord<String, KafkaPerson> fixedKeyRecord) {
-        log.info("Received key = {}, value = {}", fixedKeyRecord.key(), fixedKeyRecord.value());
+    public void process(FixedKeyRecord<String, KafkaPerson> message) {
+        log.info("Received key = {}, value = {}", message.key(), message.value());
 
         Optional<RecordMetadata> recordMetadata = context().recordMetadata();
         KafkaPersonMetadata newValue = KafkaPersonMetadata.newBuilder()
-            .setPerson(fixedKeyRecord.value())
+            .setPerson(message.value())
             .setTopic(recordMetadata.map(RecordMetadata::topic).orElse(null))
             .setPartition(recordMetadata.map(RecordMetadata::partition).orElse(null))
             .setOffset(recordMetadata.map(RecordMetadata::offset).orElse(null))
             .build();
 
-        fixedKeyRecord.headers().add("headerKey", "headerValue".getBytes(StandardCharsets.UTF_8));
-        context().forward(fixedKeyRecord.withValue(newValue));
+        message.headers().add("headerKey", "headerValue".getBytes(StandardCharsets.UTF_8));
+        context().forward(message.withValue(newValue));
     }
 }