KAFKA-16448: Remove source raw key and source raw value from ErrorHan…

…dlerContext
apache · Jul 29, 2024 · f6ed984 · f6ed984
1 parent c5d9bc1
commit f6ed984
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ms/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java b/...ms/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
@@ -307,8 +307,7 @@ private void reprocessState(final List<TopicPartition> topicPartitions,
                             record.offset(),
                             record.partition(),
                             record.topic(),
-                            record.headers()
-                        );
+                            record.headers());
                     globalProcessorContext.setRecordContext(recordContext);
 
                     try {