Browse Source

MINOR: don't require key serde in join materialized (#7557)

Reviewers: Bill Bejeck <bill@confluent.io>, Guozhang Wang <guozhang@confluent.io>, Matthias J. Sax <matthias@confluent.io>
pull/7573/head
John Roesler 5 years ago committed by Matthias J. Sax
parent
commit
7bc8c0dcd1
  1. 5
      streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java

5
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< @@ -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();

Loading…
Cancel
Save