This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch 2.4
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.4 by this push:
new 24ed6c6 MINOR: don't require key serde in join materialized (#7557)
24ed6c6 is described below
commit 24ed6c65916d0a32661400d4d07656ad115b74c4
Author: John Roesler <[email protected]>
AuthorDate: Mon Oct 21 16:25:41 2019 -0500
MINOR: don't require key serde in join materialized (#7557)
Reviewers: Bill Bejeck <[email protected]>, Guozhang Wang
<[email protected]>, Matthias J. Sax <[email protected]>
---
.../java/org/apache/kafka/streams/kstream/internals/KTableImpl.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git
a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
index 301710d..f6f2ada 100644
---
a/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
+++
b/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java
@@ -712,7 +712,10 @@ public class KTableImpl<K, S, V> extends AbstractStream<K,
V> implements KTable<
final StoreBuilder<TimestampedKeyValueStore<K, VR>> storeBuilder;
if (materializedInternal != null) {
- keySerde = materializedInternal.keySerde() != null ?
materializedInternal.keySerde() : this.keySerde;
+ if (materializedInternal.keySerde() == null) {
+ materializedInternal.withKeySerde(this.keySerde);
+ }
+ keySerde = materializedInternal.keySerde();
valueSerde = materializedInternal.valueSerde();
queryableStoreName = materializedInternal.storeName();
storeBuilder = new
TimestampedKeyValueStoreMaterializer<>(materializedInternal).materialize();
