You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2025/02/05 04:35:39 UTC
(kafka) branch trunk updated: HOTFIX: compilation error
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new a1d5dc0f9e2 HOTFIX: compilation error
a1d5dc0f9e2 is described below
commit a1d5dc0f9e2eb8a32c3db0cb89c19086fd4f6918
Author: Matthias J. Sax <ma...@confluent.io>
AuthorDate: Tue Feb 4 20:32:52 2025 -0800
HOTFIX: compilation error
Two merged PRs overlapped in a non-conflicting way, breaking compilation:
- https://github.com/apache/kafka/pull/18722
- https://github.com/apache/kafka/pull/18755
---
.../java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
index 1ce61a4bf8b..0baa8fbb72e 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
@@ -259,7 +259,7 @@ public class KStreamImpl<K, V> extends AbstractStream<K, V> implements KStream<K
Objects.requireNonNull(named, "named can't be null");
final String name = new NamedInternal(named).orElseGenerateWithPrefix(builder, MAPVALUES_NAME);
- final ProcessorParameters<K, V, K, VR> processorParameters =
+ final ProcessorParameters<K, V, K, VOut> processorParameters =
new ProcessorParameters<>(new KStreamMapValues<>(valueMapperWithKey), name);
final ProcessorGraphNode<K, V> mapValuesProcessorNode =
new ProcessorGraphNode<>(name, processorParameters);
@@ -290,7 +290,7 @@ public class KStreamImpl<K, V> extends AbstractStream<K, V> implements KStream<K
Objects.requireNonNull(named, "named can't be null");
final String name = new NamedInternal(named).orElseGenerateWithPrefix(builder, MAP_NAME);
- final ProcessorParameters<K, V, KR, VR> processorParameters =
+ final ProcessorParameters<K, V, KOut, VOut> processorParameters =
new ProcessorParameters<>(new KStreamMap<>(mapper), name);
final ProcessorGraphNode<K, V> mapProcessorNode =
new ProcessorGraphNode<>(name, processorParameters);