license

Author: astubbs

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

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

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

@@ -1,5 +1,9 @@
 package io.confluent.parallelconsumer;
 
+/*-
+ * Copyright (C) 2020-2022 Confluent, Inc.
+ */
+
 
 /**
  * Generic Parallel Consumer {@link RuntimeException} parent.

parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/internal/ParallelConsumerInternalException.java

@@ -1,5 +1,9 @@
 package io.confluent.parallelconsumer.internal;
 
+/*-
+ * Copyright (C) 2020-2022 Confluent, Inc.
+ */
+
 /**
  * Generic Parallel Consumer parent exception.
  */

parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/internal/ProducerManager.java

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

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

@@ -1,5 +1,9 @@
 package io.confluent.parallelconsumer.offsets;
 
+/*-
+ * Copyright (C) 2020-2022 Confluent, Inc.
+ */
+
 import io.confluent.parallelconsumer.internal.ParallelConsumerInternalException;
 
 /*-

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

@@ -1,5 +1,9 @@
 package io.confluent.parallelconsumer.offsets;
 
+/*-
+ * Copyright (C) 2020-2022 Confluent, Inc.
+ */
+
 import io.confluent.parallelconsumer.internal.ParallelConsumerInternalException;
 
 public class NoEncodingPossibleException extends ParallelConsumerInternalException {

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

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

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

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