diff --git a/build.gradle.kts b/build.gradle.kts
index 0197475..1b67ba2 100644
--- a/build.gradle.kts
+++ b/build.gradle.kts
@@ -16,7 +16,7 @@ allprojects {
     repositories {
         mavenCentral()
         maven(url = "https://packages.confluent.io/maven/")
-        maven(url = "https://s01.oss.sonatype.org/content/repositories/snapshots")
+        maven(url = "https://central.sonatype.com/repository/maven-snapshots")
     }
 }
 
diff --git a/error-handling-core/src/main/java/com/bakdata/kafka/ErrorCapturingProcessor.java b/error-handling-core/src/main/java/com/bakdata/kafka/ErrorCapturingProcessor.java
index ee830f9..27fd2c1 100644
--- a/error-handling-core/src/main/java/com/bakdata/kafka/ErrorCapturingProcessor.java
+++ b/error-handling-core/src/main/java/com/bakdata/kafka/ErrorCapturingProcessor.java
@@ -68,7 +68,7 @@ public final class ErrorCapturingProcessor<K, V, KR, VR>
      * @see ErrorUtil#isRecoverable(Exception)
      */
     public static <K, V, KR, VR> Processor<K, V, KR, ProcessedKeyValue<K, V, VR>> captureErrors(
-            final @NonNull Processor<? super K, ? super V, KR, VR> processor) {
+            final @NonNull Processor<? super K, ? super V, ? extends KR, ? extends VR> processor) {
         return captureErrors(processor, ErrorUtil::isRecoverable);
     }
 
@@ -91,7 +91,7 @@ public static <K, V, KR, VR> Processor<K, V, KR, ProcessedKeyValue<K, V, VR>> ca
      * @return {@code Processor}
      */
     public static <K, V, KR, VR> Processor<K, V, KR, ProcessedKeyValue<K, V, VR>> captureErrors(
-            final @NonNull Processor<? super K, ? super V, KR, VR> processor,
+            final @NonNull Processor<? super K, ? super V, ? extends KR, ? extends VR> processor,
             final @NonNull Predicate<Exception> errorFilter) {
         return new ErrorCapturingProcessor<>((Processor<K, V, KR, VR>) processor, errorFilter);
     }
@@ -110,7 +110,7 @@ public static <K, V, KR, VR> Processor<K, V, KR, ProcessedKeyValue<K, V, VR>> ca
      * @see ErrorUtil#isRecoverable(Exception)
      */
     public static <K, V, KR, VR> ProcessorSupplier<K, V, KR, ProcessedKeyValue<K, V, VR>> captureErrors(
-            final @NonNull ProcessorSupplier<? super K, ? super V, KR, VR> supplier) {
+            final @NonNull ProcessorSupplier<? super K, ? super V, ? extends KR, ? extends VR> supplier) {
         return captureErrors(supplier, ErrorUtil::isRecoverable);
     }
 
@@ -134,7 +134,7 @@ public static <K, V, KR, VR> ProcessorSupplier<K, V, KR, ProcessedKeyValue<K, V,
      * @return {@code ProcessorSupplier}
      */
     public static <K, V, KR, VR> ProcessorSupplier<K, V, KR, ProcessedKeyValue<K, V, VR>> captureErrors(
-            final @NonNull ProcessorSupplier<? super K, ? super V, KR, VR> supplier,
+            final @NonNull ProcessorSupplier<? super K, ? super V, ? extends KR, ? extends VR> supplier,
             final @NonNull Predicate<Exception> errorFilter) {
         return new ProcessorSupplier<>() {
             @Override
diff --git a/error-handling-core/src/main/java/com/bakdata/kafka/ErrorCapturingValueProcessor.java b/error-handling-core/src/main/java/com/bakdata/kafka/ErrorCapturingValueProcessor.java
index 6b929da..f256d37 100644
--- a/error-handling-core/src/main/java/com/bakdata/kafka/ErrorCapturingValueProcessor.java
+++ b/error-handling-core/src/main/java/com/bakdata/kafka/ErrorCapturingValueProcessor.java
@@ -66,7 +66,7 @@ public final class ErrorCapturingValueProcessor<K, V, VR>
      * @see ErrorUtil#isRecoverable(Exception)
      */
     public static <K, V, VR> FixedKeyProcessor<K, V, ProcessedValue<V, VR>> captureErrors(
-            final @NonNull FixedKeyProcessor<? super K, ? super V, VR> processor) {
+            final @NonNull FixedKeyProcessor<? super K, ? super V, ? extends VR> processor) {
         return captureErrors(processor, ErrorUtil::isRecoverable);
     }
 
@@ -88,7 +88,7 @@ public static <K, V, VR> FixedKeyProcessor<K, V, ProcessedValue<V, VR>> captureE
      * @return {@code FixedKeyProcessor}
      */
     public static <K, V, VR> FixedKeyProcessor<K, V, ProcessedValue<V, VR>> captureErrors(
-            final @NonNull FixedKeyProcessor<? super K, ? super V, VR> processor,
+            final @NonNull FixedKeyProcessor<? super K, ? super V, ? extends VR> processor,
             final @NonNull Predicate<Exception> errorFilter) {
         return new ErrorCapturingValueProcessor<>((FixedKeyProcessor<K, V, VR>) processor, errorFilter);
     }
@@ -106,7 +106,7 @@ public static <K, V, VR> FixedKeyProcessor<K, V, ProcessedValue<V, VR>> captureE
      * @see ErrorUtil#isRecoverable(Exception)
      */
     public static <K, V, VR> FixedKeyProcessorSupplier<K, V, ProcessedValue<V, VR>> captureErrors(
-            final @NonNull FixedKeyProcessorSupplier<? super K, ? super V, VR> supplier) {
+            final @NonNull FixedKeyProcessorSupplier<? super K, ? super V, ? extends VR> supplier) {
         return captureErrors(supplier, ErrorUtil::isRecoverable);
     }
 
@@ -129,7 +129,7 @@ public static <K, V, VR> FixedKeyProcessorSupplier<K, V, ProcessedValue<V, VR>>
      * @return {@code FixedKeyProcessorSupplier}
      */
     public static <K, V, VR> FixedKeyProcessorSupplier<K, V, ProcessedValue<V, VR>> captureErrors(
-            final @NonNull FixedKeyProcessorSupplier<? super K, ? super V, VR> supplier,
+            final @NonNull FixedKeyProcessorSupplier<? super K, ? super V, ? extends VR> supplier,
             final @NonNull Predicate<Exception> errorFilter) {
         return new FixedKeyProcessorSupplier<>() {
             @Override
diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml
index 34c6bc0..6104413 100644
--- a/gradle/libs.versions.toml
+++ b/gradle/libs.versions.toml
@@ -4,7 +4,7 @@ junit = "5.13.3"
 mockito = "5.18.0"
 
 [libraries]
-kafka-bom = { group = "com.bakdata.kafka", name = "kafka-bom", version = "1.2.1" }
+kafka-bom = { group = "com.bakdata.kafka", name = "kafka-bom", version = "1.2.2-SNAPSHOT" }
 kafka-streams = { group = "org.apache.kafka", name = "kafka-streams" }
 kafka-streams-avro-serde = { group = "io.confluent", name = "kafka-streams-avro-serde" }
 kafka-streams-protobuf-serde = { group = "io.confluent", name = "kafka-streams-protobuf-serde" }