fix: example in readme, license headers

README.adoc

@@ -1190,6 +1190,26 @@ Following example illustrates setup of Parallel Consumer with Meter Registry and
 
 [source,java,indent=0]
 ----
+    ParallelStreamProcessor<String, String> setupParallelConsumer() {
+        Consumer<String, String> kafkaConsumer = getKafkaConsumer();
+
+        var options = ParallelConsumerOptions.<String, String>builder()
+                .ordering(ParallelConsumerOptions.ProcessingOrder.KEY)
+                .maxConcurrency(1000)
+                .consumer(kafkaConsumer)
+                .meterRegistry(meterRegistry)                     //<1>
+                .metricsTags(Tags.of(Tag.of("instance", "pc1")))    //<2>
+                .build();
+
+        ParallelStreamProcessor<String, String> eosStreamProcessor =
+                ParallelStreamProcessor.createEosStreamProcessor(options);
+
+        eosStreamProcessor.subscribe(of(inputTopic));
+
+        kafkaClientMetrics = new KafkaClientMetrics(kafkaConsumer); //<3>
+        kafkaClientMetrics.bindTo(meterRegistry);                 //<4>
+        return eosStreamProcessor;
+    }
 ----
 <1> - Optional - Kafka Consumer Micrometer metrics object created for Kafka Consumer that is later used for Parallel Consumer.
 <2> - Optional - Kafka Consumer Micrometer metrics are bound to Meter Registry.

parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/metrics/PCMetrics.java

@@ -15,11 +15,11 @@
 
 import static java.util.Collections.emptyList;
 
-@Slf4j
 /**
  * Main metrics collection and initialization service.
  * Singleton - makes it easier to add metrics throughout the code
  */
+@Slf4j
 public class PCMetrics {
     private static PCMetrics instance;
 

parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/offsets/OffsetEncoder.java

@@ -1,7 +1,7 @@
 package io.confluent.parallelconsumer.offsets;
 
 /*-
- * Copyright (C) 2020-2022 Confluent, Inc.
+ * Copyright (C) 2020-2023 Confluent, Inc.
  */
 
 import lombok.SneakyThrows;

parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/state/RemovedPartitionState.java

@@ -1,7 +1,7 @@
 package io.confluent.parallelconsumer.state;
 
 /*-
- * Copyright (C) 2020-2022 Confluent, Inc.
+ * Copyright (C) 2020-2023 Confluent, Inc.
  */
 
 import io.confluent.csid.utils.KafkaUtils;

parallel-consumer-core/src/test/java/io/confluent/parallelconsumer/ParallelEoSStreamProcessorTestBase.java

@@ -1,7 +1,7 @@
 package io.confluent.parallelconsumer;
 
 /*-
- * Copyright (C) 2020-2022 Confluent, Inc.
+ * Copyright (C) 2020-2023 Confluent, Inc.
  */
 
 import io.confluent.parallelconsumer.internal.AbstractParallelEoSStreamProcessor;

parallel-consumer-examples/parallel-consumer-example-metrics/src/main/java/io/confluent/parallelconsumer/examples/metrics/CoreApp.java

@@ -90,6 +90,7 @@ protected void postSetup() {
     }
 
     @SuppressWarnings({"FeatureEnvy", "MagicNumber" })
+    // tag::example[]
     ParallelStreamProcessor<String, String> setupParallelConsumer() {
         Consumer<String, String> kafkaConsumer = getKafkaConsumer();
 
@@ -110,6 +111,7 @@ ParallelStreamProcessor<String, String> setupParallelConsumer() {
         kafkaClientMetrics.bindTo(meterRegistry);                 //<4>
         return eosStreamProcessor;
     }
+    // end::example[]
 
     void close() {
         this.kafkaClientMetrics.close();