Upgrade to Kafka 3.8 and Avro 1.12

bakdata · Jan 7, 2025 · 330774e · 330774e
1 parent 0dd243a
commit 330774e
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 0 deletions.
diff --git a/...ndling-core/src/test/java/com/bakdata/kafka/ErrorCapturingValueProcessorTopologyTest.java b/...ndling-core/src/test/java/com/bakdata/kafka/ErrorCapturingValueProcessorTopologyTest.java
@@ -99,6 +99,7 @@ void shouldForwardRecoverableException(final SoftAssertions softly) {
 
             @Override
             public void init(final FixedKeyProcessorContext<Integer, Long> context) {
+                // do nothing
             }
 
             @Override
@@ -140,6 +141,7 @@ void shouldNotCaptureThrowable(final SoftAssertions softly) {
 
             @Override
             public void init(final FixedKeyProcessorContext<Integer, Long> context) {
+                // do nothing
             }
 
             @Override
@@ -286,6 +288,7 @@ void shouldHandleErrorOnNullInput(final SoftAssertions softly) {
 
             @Override
             public void init(final FixedKeyProcessorContext<Integer, Long> context) {
+                // do nothing
             }
 
             @Override

diff --git a/...dling-core/src/test/java/com/bakdata/kafka/ErrorDescribingValueProcessorTopologyTest.java b/...dling-core/src/test/java/com/bakdata/kafka/ErrorDescribingValueProcessorTopologyTest.java
@@ -186,6 +186,7 @@ void shouldHandleErrorOnNullInput(final SoftAssertions softly) {
 
             @Override
             public void init(final FixedKeyProcessorContext<Integer, Long> context) {
+                // do nothing
             }
 
             @Override

diff --git a/...handling-core/src/test/java/com/bakdata/kafka/ErrorLoggingValueProcessorTopologyTest.java b/...handling-core/src/test/java/com/bakdata/kafka/ErrorLoggingValueProcessorTopologyTest.java
@@ -93,6 +93,7 @@ void shouldForwardRecoverableException(final SoftAssertions softly) {
 
             @Override
             public void init(final FixedKeyProcessorContext<Integer, Long> context) {
+                // do nothing
             }
 
             @Override
@@ -127,6 +128,7 @@ void shouldNotCaptureThrowable(final SoftAssertions softly) {
 
             @Override
             public void init(final FixedKeyProcessorContext<Integer, Long> context) {
+                // do nothing
             }
 
             @Override
@@ -245,6 +247,7 @@ void shouldHandleErrorOnNullInput(final SoftAssertions softly) {
 
             @Override
             public void init(final FixedKeyProcessorContext<Integer, Long> context) {
+                // do nothing
             }
 
             @Override