Package org.apache.kafka.streams.kstream

Class KStreamBuilder

java.lang.Object

org.apache.kafka.streams.processor.TopologyBuilder

org.apache.kafka.streams.kstream.KStreamBuilder

Deprecated.

Use StreamsBuilder instead

@Deprecated
public class KStreamBuilder
extends TopologyBuilder

KStreamBuilder provide the high-level Kafka Streams DSL to specify a Kafka Streams topology.

See Also:

TopologyBuilder, KStream, KTable, GlobalKTable

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.kafka.streams.processor.TopologyBuilder

TopologyBuilder.AutoOffsetReset, TopologyBuilder.TopicsInfo

Field Summary

Fields inherited from class org.apache.kafka.streams.processor.TopologyBuilder

internalTopologyBuilder

Constructor Summary

Constructors

Constructor	Description
KStreamBuilder()	Deprecated.

Method Summary

Modifier and Type	Method	Description
<K,V> GlobalKTable<K,V>	globalTable(java.lang.String topic)	Deprecated. Create a GlobalKTable for the specified topic.
<K,V> GlobalKTable<K,V>	globalTable(java.lang.String topic, java.lang.String queryableStoreName)	Deprecated. Create a GlobalKTable for the specified topic.
<K,V> GlobalKTable<K,V>	globalTable(Serde<K> keySerde, Serde<V> valSerde, java.lang.String topic)	Deprecated. Create a GlobalKTable for the specified topic.
<K,V> GlobalKTable<K,V>	globalTable(Serde<K> keySerde, Serde<V> valSerde, java.lang.String topic, java.lang.String queryableStoreName)	Deprecated. Create a GlobalKTable for the specified topic.
<K,V> GlobalKTable<K,V>	globalTable(Serde<K> keySerde, Serde<V> valSerde, java.lang.String topic, StateStoreSupplier<KeyValueStore> storeSupplier)	Deprecated. Create a GlobalKTable for the specified topic.
<K,V> GlobalKTable<K,V>	globalTable(Serde<K> keySerde, Serde<V> valSerde, TimestampExtractor timestampExtractor, java.lang.String topic, java.lang.String queryableStoreName)	Deprecated. Create a GlobalKTable for the specified topic.
<K,V> KStream<K,V>	merge(KStream<K,V>... streams)	Deprecated. Create a new instance of KStream by merging the given KStreams.
java.lang.String	newName(java.lang.String prefix)	Deprecated. This function is only for internal usage only and should not be called.
java.lang.String	newStoreName(java.lang.String prefix)	Deprecated. This function is only for internal usage only and should not be called.
<K,V> KStream<K,V>	stream(java.lang.String... topics)	Deprecated. Create a KStream from the specified topics.
<K,V> KStream<K,V>	stream(java.util.regex.Pattern topicPattern)	Deprecated. Create a KStream from the specified topic pattern.
<K,V> KStream<K,V>	stream(Serde<K> keySerde, Serde<V> valSerde, java.lang.String... topics)	Deprecated. Create a KStream from the specified topics.
<K,V> KStream<K,V>	stream(Serde<K> keySerde, Serde<V> valSerde, java.util.regex.Pattern topicPattern)	Deprecated. Create a KStream from the specified topic pattern.
<K,V> KStream<K,V>	stream(TimestampExtractor timestampExtractor, Serde<K> keySerde, Serde<V> valSerde, java.lang.String... topics)	Deprecated. Create a KStream from the specified topics.
<K,V> KStream<K,V>	stream(TimestampExtractor timestampExtractor, Serde<K> keySerde, Serde<V> valSerde, java.util.regex.Pattern topicPattern)	Deprecated. Create a KStream from the specified topic pattern.
<K,V> KStream<K,V>	stream(TopologyBuilder.AutoOffsetReset offsetReset, java.lang.String... topics)	Deprecated. Create a KStream from the specified topics.
<K,V> KStream<K,V>	stream(TopologyBuilder.AutoOffsetReset offsetReset, java.util.regex.Pattern topicPattern)	Deprecated. Create a KStream from the specified topic pattern.
<K,V> KStream<K,V>	stream(TopologyBuilder.AutoOffsetReset offsetReset, Serde<K> keySerde, Serde<V> valSerde, java.lang.String... topics)	Deprecated. Create a KStream from the specified topics.
<K,V> KStream<K,V>	stream(TopologyBuilder.AutoOffsetReset offsetReset, Serde<K> keySerde, Serde<V> valSerde, java.util.regex.Pattern topicPattern)	Deprecated. Create a KStream from the specified topic pattern.
<K,V> KStream<K,V>	stream(TopologyBuilder.AutoOffsetReset offsetReset, TimestampExtractor timestampExtractor, Serde<K> keySerde, Serde<V> valSerde, java.lang.String... topics)	Deprecated. Create a KStream from the specified topics.
<K,V> KStream<K,V>	stream(TopologyBuilder.AutoOffsetReset offsetReset, TimestampExtractor timestampExtractor, Serde<K> keySerde, Serde<V> valSerde, java.util.regex.Pattern topicPattern)	Deprecated. Create a KStream from the specified topic pattern.
<K,V> KTable<K,V>	table(java.lang.String topic)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(java.lang.String topic, java.lang.String queryableStoreName)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(java.lang.String topic, StateStoreSupplier<KeyValueStore> storeSupplier)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(Serde<K> keySerde, Serde<V> valSerde, java.lang.String topic)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(Serde<K> keySerde, Serde<V> valSerde, java.lang.String topic, java.lang.String queryableStoreName)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(Serde<K> keySerde, Serde<V> valSerde, java.lang.String topic, StateStoreSupplier<KeyValueStore> storeSupplier)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(TimestampExtractor timestampExtractor, java.lang.String topic, java.lang.String storeName)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(TimestampExtractor timestampExtractor, Serde<K> keySerde, Serde<V> valSerde, java.lang.String topic, java.lang.String storeName)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(TopologyBuilder.AutoOffsetReset offsetReset, java.lang.String topic)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(TopologyBuilder.AutoOffsetReset offsetReset, java.lang.String topic, java.lang.String queryableStoreName)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(TopologyBuilder.AutoOffsetReset offsetReset, java.lang.String topic, StateStoreSupplier<KeyValueStore> storeSupplier)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(TopologyBuilder.AutoOffsetReset offsetReset, Serde<K> keySerde, Serde<V> valSerde, java.lang.String topic)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(TopologyBuilder.AutoOffsetReset offsetReset, Serde<K> keySerde, Serde<V> valSerde, java.lang.String topic, java.lang.String queryableStoreName)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(TopologyBuilder.AutoOffsetReset offsetReset, TimestampExtractor timestampExtractor, java.lang.String topic, java.lang.String storeName)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(TopologyBuilder.AutoOffsetReset offsetReset, TimestampExtractor timestampExtractor, Serde<K> keySerde, Serde<V> valSerde, java.lang.String topic, java.lang.String queryableStoreName)	Deprecated. Create a KTable for the specified topic.
<K,V> KTable<K,V>	table(TopologyBuilder.AutoOffsetReset offsetReset, TimestampExtractor timestampExtractor, Serde<K> keySerde, Serde<V> valSerde, java.lang.String topic, StateStoreSupplier<KeyValueStore> storeSupplier)	Deprecated. Create a KTable for the specified topic.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from class org.apache.kafka.streams.processor.TopologyBuilder

addGlobalStore, addGlobalStore, addInternalTopic, addProcessor, addSink, addSink, addSink, addSink, addSource, addSource, addSource, addSource, addSource, addSource, addSource, addSource, addSource, addSource, addSource, addSource, addSource, addStateStore, build, buildGlobalStateTopology, connectProcessorAndStateStores, connectProcessors, connectSourceStoreAndTopic, copartitionGroups, copartitionSources, earliestResetTopicsPattern, globalStateStores, latestResetTopicsPattern, nodeGroups, setApplicationId, sourceTopicPattern, stateStoreNameToSourceTopics, subscriptionUpdates, topicGroups, updateSubscriptions

Constructor Detail

KStreamBuilder

public KStreamBuilder()

Deprecated.

Method Detail

stream

public <K,V> KStream<K,V> stream(java.lang.String... topics)

Deprecated.

Create a KStream from the specified topics. The default "auto.offset.reset" strategy, default TimestampExtractor, and default key and value deserializers as specified in the config are used.

If multiple topics are specified there is no ordering guarantee for records from different topics.

Note that the specified input topics must be partitioned by key. If this is not the case it is the user's responsibility to repartition the date before any key based operation (like aggregation or join) is applied to the returned KStream.

Parameters:

topics - the topic names; must contain at least one topic name

Returns:

a KStream for the specified topics

stream

public <K,V> KStream<K,V> stream(TopologyBuilder.AutoOffsetReset offsetReset,
                                 java.lang.String... topics)

Deprecated.

Create a KStream from the specified topics. The default TimestampExtractor and default key and value deserializers as specified in the config are used.

If multiple topics are specified there is no ordering guarantee for records from different topics.

Note that the specified input topics must be partitioned by key. If this is not the case it is the user's responsibility to repartition the date before any key based operation (like aggregation or join) is applied to the returned KStream.

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the specified topics if no valid committed offsets are available

topics - the topic names; must contain at least one topic name

Returns:

a KStream for the specified topics

stream

public <K,V> KStream<K,V> stream(java.util.regex.Pattern topicPattern)

Deprecated.

Create a KStream from the specified topic pattern. The default "auto.offset.reset" strategy, default TimestampExtractor, and default key and value deserializers as specified in the config are used.

If multiple topics are matched by the specified pattern, the created KStream will read data from all of them and there is no ordering guarantee between records from different topics.

Note that the specified input topics must be partitioned by key. If this is not the case it is the user's responsibility to repartition the date before any key based operation (like aggregation or join) is applied to the returned KStream.

Parameters:

topicPattern - the pattern to match for topic names

Returns:

a KStream for topics matching the regex pattern.

stream

public <K,V> KStream<K,V> stream(TopologyBuilder.AutoOffsetReset offsetReset,
                                 java.util.regex.Pattern topicPattern)

Deprecated.

Create a KStream from the specified topic pattern. The default TimestampExtractor and default key and value deserializers as specified in the config are used.

If multiple topics are matched by the specified pattern, the created KStream will read data from all of them and there is no ordering guarantee between records from different topics.

Note that the specified input topics must be partitioned by key. If this is not the case it is the user's responsibility to repartition the date before any key based operation (like aggregation or join) is applied to the returned KStream.

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the matched topics if no valid committed offsets are available

topicPattern - the pattern to match for topic names

Returns:

a KStream for topics matching the regex pattern.

stream

public <K,V> KStream<K,V> stream(Serde<K> keySerde,
                                 Serde<V> valSerde,
                                 java.lang.String... topics)

Deprecated.

Create a KStream from the specified topics. The default "auto.offset.reset" strategy and default TimestampExtractor as specified in the config are used.

If multiple topics are specified there is no ordering guarantee for records from different topics.

Note that the specified input topics must be partitioned by key. If this is not the case it is the user's responsibility to repartition the date before any key based operation (like aggregation or join) is applied to the returned KStream.

Parameters:

keySerde - key serde used to read this source KStream, if not specified the default serde defined in the configs will be used

valSerde - value serde used to read this source KStream, if not specified the default serde defined in the configs will be used

topics - the topic names; must contain at least one topic name

Returns:

a KStream for the specified topics

stream

public <K,V> KStream<K,V> stream(TopologyBuilder.AutoOffsetReset offsetReset,
                                 Serde<K> keySerde,
                                 Serde<V> valSerde,
                                 java.lang.String... topics)

Deprecated.

Create a KStream from the specified topics. The default TimestampExtractor as specified in the config is used.

If multiple topics are specified there is no ordering guarantee for records from different topics.

Note that the specified input topics must be partitioned by key. If this is not the case it is the user's responsibility to repartition the date before any key based operation (like aggregation or join) is applied to the returned KStream.

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the specified topics if no valid committed offsets are available

keySerde - key serde used to read this source KStream, if not specified the default serde defined in the configs will be used

valSerde - value serde used to read this source KStream, if not specified the default serde defined in the configs will be used

topics - the topic names; must contain at least one topic name

Returns:

a KStream for the specified topics

stream

public <K,V> KStream<K,V> stream(TimestampExtractor timestampExtractor,
                                 Serde<K> keySerde,
                                 Serde<V> valSerde,
                                 java.lang.String... topics)

Deprecated.

Create a KStream from the specified topics. The default "auto.offset.reset" strategy as specified in the config is used.

If multiple topics are specified there is no ordering guarantee for records from different topics.

Note that the specified input topics must be partitioned by key. If this is not the case it is the user's responsibility to repartition the date before any key based operation (like aggregation or join) is applied to the returned KStream.

Parameters:

timestampExtractor - the stateless timestamp extractor used for this source KStream, if not specified the default extractor defined in the configs will be used

keySerde - key serde used to read this source KStream, if not specified the default serde defined in the configs will be used

valSerde - value serde used to read this source KStream, if not specified the default serde defined in the configs will be used

topics - the topic names; must contain at least one topic name

Returns:

a KStream for the specified topics

stream

public <K,V> KStream<K,V> stream(TopologyBuilder.AutoOffsetReset offsetReset,
                                 TimestampExtractor timestampExtractor,
                                 Serde<K> keySerde,
                                 Serde<V> valSerde,
                                 java.lang.String... topics)

Deprecated.

Create a KStream from the specified topics.

If multiple topics are specified there is no ordering guarantee for records from different topics.

Note that the specified input topics must be partitioned by key. If this is not the case it is the user's responsibility to repartition the date before any key based operation (like aggregation or join) is applied to the returned KStream.

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the specified topics if no valid committed offsets are available

timestampExtractor - the stateless timestamp extractor used for this source KStream, if not specified the default extractor defined in the configs will be used

keySerde - key serde used to read this source KStream, if not specified the default serde defined in the configs will be used

valSerde - value serde used to read this source KStream, if not specified the default serde defined in the configs will be used

topics - the topic names; must contain at least one topic name

Returns:

a KStream for the specified topics

stream

public <K,V> KStream<K,V> stream(Serde<K> keySerde,
                                 Serde<V> valSerde,
                                 java.util.regex.Pattern topicPattern)

Deprecated.

Create a KStream from the specified topic pattern. The default "auto.offset.reset" strategy and default TimestampExtractor as specified in the config are used.

If multiple topics are matched by the specified pattern, the created KStream will read data from all of them and there is no ordering guarantee between records from different topics.

Note that the specified input topics must be partitioned by key. If this is not the case it is the user's responsibility to repartition the date before any key based operation (like aggregation or join) is applied to the returned KStream.

Parameters:

keySerde - key serde used to read this source KStream, if not specified the default serde defined in the configs will be used

valSerde - value serde used to read this source KStream, if not specified the default serde defined in the configs will be used

topicPattern - the pattern to match for topic names

Returns:

a KStream for topics matching the regex pattern.

stream

public <K,V> KStream<K,V> stream(TopologyBuilder.AutoOffsetReset offsetReset,
                                 Serde<K> keySerde,
                                 Serde<V> valSerde,
                                 java.util.regex.Pattern topicPattern)

Deprecated.

Create a KStream from the specified topic pattern. The default TimestampExtractor as specified in the config is used.

If multiple topics are matched by the specified pattern, the created KStream will read data from all of them and there is no ordering guarantee between records from different topics.

Note that the specified input topics must be partitioned by key. If this is not the case it is the user's responsibility to repartition the date before any key based operation (like aggregation or join) is applied to the returned KStream.

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the matched topics if no valid committed offsets are available

keySerde - key serde used to read this source KStream, if not specified the default serde defined in the configs will be used

valSerde - value serde used to read this source KStream, if not specified the default serde defined in the configs will be used

topicPattern - the pattern to match for topic names

Returns:

a KStream for topics matching the regex pattern.

stream

public <K,V> KStream<K,V> stream(TimestampExtractor timestampExtractor,
                                 Serde<K> keySerde,
                                 Serde<V> valSerde,
                                 java.util.regex.Pattern topicPattern)

Deprecated.

Create a KStream from the specified topic pattern. The default "auto.offset.reset" strategy as specified in the config is used.

If multiple topics are matched by the specified pattern, the created KStream will read data from all of them and there is no ordering guarantee between records from different topics.

Note that the specified input topics must be partitioned by key. If this is not the case it is the user's responsibility to repartition the date before any key based operation (like aggregation or join) is applied to the returned KStream.

Parameters:

timestampExtractor - the stateless timestamp extractor used for this source KStream, if not specified the default extractor defined in the configs will be used

keySerde - key serde used to read this source KStream, if not specified the default serde defined in the configs will be used

valSerde - value serde used to read this source KStream, if not specified the default serde defined in the configs will be used

topicPattern - the pattern to match for topic names

Returns:

a KStream for topics matching the regex pattern.

stream

public <K,V> KStream<K,V> stream(TopologyBuilder.AutoOffsetReset offsetReset,
                                 TimestampExtractor timestampExtractor,
                                 Serde<K> keySerde,
                                 Serde<V> valSerde,
                                 java.util.regex.Pattern topicPattern)

Deprecated.

Create a KStream from the specified topic pattern.

If multiple topics are matched by the specified pattern, the created KStream will read data from all of them and there is no ordering guarantee between records from different topics.

Note that the specified input topics must be partitioned by key. If this is not the case it is the user's responsibility to repartition the date before any key based operation (like aggregation or join) is applied to the returned KStream.

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the matched topics if no valid committed offsets are available

timestampExtractor - the stateless timestamp extractor used for this source KStream, if not specified the default extractor defined in the configs will be used

keySerde - key serde used to read this source KStream, if not specified the default serde defined in the configs will be used

valSerde - value serde used to read this source KStream, if not specified the default serde defined in the configs will be used

topicPattern - the pattern to match for topic names

Returns:

a KStream for topics matching the regex pattern.

table

public <K,V> KTable<K,V> table(java.lang.String topic,
                               java.lang.String queryableStoreName)

Deprecated.

Create a KTable for the specified topic. The default "auto.offset.reset" strategy, default TimestampExtractor, and default key and value deserializers as specified in the config are used. Input records with null key will be dropped.

Note that the specified input topic must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with the given queryableStoreName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(queryableStoreName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key); // key must be local (application state is shared over all running Kafka Streams instances)
 

For non-local keys, a custom RPC mechanism must be implemented using KafkaStreams.allMetadata() to query the value of the key on a parallel running instance of your Kafka Streams application.

Parameters:

topic - the topic name; cannot be null

queryableStoreName - the state store name; If null this is the equivalent of table(String) ()}.

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(java.lang.String topic,
                               StateStoreSupplier<KeyValueStore> storeSupplier)

Deprecated.

Create a KTable for the specified topic. The default "auto.offset.reset" strategy and default key and value deserializers as specified in the config are used. Input records with null key will be dropped.

Note that the specified input topics must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with the given queryableStoreName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(queryableStoreName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key); // key must be local (application state is shared over all running Kafka Streams instances)
 

For non-local keys, a custom RPC mechanism must be implemented using KafkaStreams.allMetadata() to query the value of the key on a parallel running instance of your Kafka Streams application.

Parameters:

topic - the topic name; cannot be null

storeSupplier - user defined state store supplier. Cannot be null.

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(java.lang.String topic)

Deprecated.

Create a KTable for the specified topic. The default "auto.offset.reset" strategy and default key and value deserializers as specified in the config are used. Input records with null key will be dropped.

Note that the specified input topics must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with an internal store name. Note that store name may not be queriable through Interactive Queries. No internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

Parameters:

topic - the topic name; cannot be null

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(TopologyBuilder.AutoOffsetReset offsetReset,
                               java.lang.String topic,
                               java.lang.String queryableStoreName)

Deprecated.

Create a KTable for the specified topic. The default key and value deserializers as specified in the config are used. Input records with null key will be dropped.

Note that the specified input topics must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with the given queryableStoreName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(queryableStoreName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key); // key must be local (application state is shared over all running Kafka Streams instances)
 

For non-local keys, a custom RPC mechanism must be implemented using KafkaStreams.allMetadata() to query the value of the key on a parallel running instance of your Kafka Streams application.

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the specified topic if no valid committed offsets are available

topic - the topic name; cannot be null

queryableStoreName - the state store name; If null this is the equivalent of table(AutoOffsetReset, String).

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(TopologyBuilder.AutoOffsetReset offsetReset,
                               java.lang.String topic,
                               StateStoreSupplier<KeyValueStore> storeSupplier)

Deprecated.

Create a KTable for the specified topic. The default TimestampExtractor and default key and value deserializers as specified in the config are used. Input records with null key will be dropped.

Note that the specified input topic must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with the given queryableStoreName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(queryableStoreName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key); // key must be local (application state is shared over all running Kafka Streams instances)
 

For non-local keys, a custom RPC mechanism must be implemented using KafkaStreams.allMetadata() to query the value of the key on a parallel running instance of your Kafka Streams application.

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the specified topic if no valid committed offsets are available

topic - the topic name; cannot be null

storeSupplier - user defined state store supplier. Cannot be null.

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(TopologyBuilder.AutoOffsetReset offsetReset,
                               java.lang.String topic)

Deprecated.

Create a KTable for the specified topic. The default key and value deserializers as specified in the config are used. Input records with null key will be dropped.

Note that the specified input topics must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with an internal store name. Note that store name may not be queriable through Interactive Queries. No internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the specified topic if no valid committed offsets are available

topic - the topic name; cannot be null

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(TimestampExtractor timestampExtractor,
                               java.lang.String topic,
                               java.lang.String storeName)

Deprecated.

Create a KTable for the specified topic. The default "auto.offset.reset" strategy and default key and value deserializers as specified in the config are used. Input KeyValue pairs with null key will be dropped.

Note that the specified input topic must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with the given storeName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(storeName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key); // key must be local (application state is shared over all running Kafka Streams instances)
 

For non-local keys, a custom RPC mechanism must be implemented using KafkaStreams.allMetadata() to query the value of the key on a parallel running instance of your Kafka Streams application.

Parameters:

timestampExtractor - the stateless timestamp extractor used for this source KTable, if not specified the default extractor defined in the configs will be used

topic - the topic name; cannot be null

storeName - the state store name; cannot be null

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(TopologyBuilder.AutoOffsetReset offsetReset,
                               TimestampExtractor timestampExtractor,
                               java.lang.String topic,
                               java.lang.String storeName)

Deprecated.

Create a KTable for the specified topic. The default key and value deserializers as specified in the config are used. Input KeyValue pairs with null key will be dropped.

Note that the specified input topic must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with the given storeName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(storeName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key); // key must be local (application state is shared over all running Kafka Streams instances)
 

For non-local keys, a custom RPC mechanism must be implemented using KafkaStreams.allMetadata() to query the value of the key on a parallel running instance of your Kafka Streams application.

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the specified topic if no valid committed offsets are available

topic - the topic name; cannot be null

storeName - the state store name; cannot be null

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(Serde<K> keySerde,
                               Serde<V> valSerde,
                               java.lang.String topic,
                               java.lang.String queryableStoreName)

Deprecated.

Create a KTable for the specified topic. The default "auto.offset.reset" strategy and default TimestampExtractor as specified in the config are used. Input records with null key will be dropped.

Note that the specified input topic must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with the given queryableStoreName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(queryableStoreName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key); // key must be local (application state is shared over all running Kafka Streams instances)
 

For non-local keys, a custom RPC mechanism must be implemented using KafkaStreams.allMetadata() to query the value of the key on a parallel running instance of your Kafka Streams application.

Parameters:

keySerde - key serde used to send key-value pairs, if not specified the default key serde defined in the configuration will be used

valSerde - value serde used to send key-value pairs, if not specified the default value serde defined in the configuration will be used

topic - the topic name; cannot be null

queryableStoreName - the state store name; If null this is the equivalent of table(Serde, Serde, String) ()}.

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(Serde<K> keySerde,
                               Serde<V> valSerde,
                               java.lang.String topic,
                               StateStoreSupplier<KeyValueStore> storeSupplier)

Deprecated.

Create a KTable for the specified topic. The default TimestampExtractor as specified in the config is used. The default "auto.offset.reset" strategy as specified in the config is used. Input records with null key will be dropped.

Note that the specified input topic must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with the given queryableStoreName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(queryableStoreName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key); // key must be local (application state is shared over all running Kafka Streams instances)
 

For non-local keys, a custom RPC mechanism must be implemented using KafkaStreams.allMetadata() to query the value of the key on a parallel running instance of your Kafka Streams application.

Parameters:

keySerde - key serde used to send key-value pairs, if not specified the default key serde defined in the configuration will be used

valSerde - value serde used to send key-value pairs, if not specified the default value serde defined in the configuration will be used

topic - the topic name; cannot be null

storeSupplier - user defined state store supplier. Cannot be null.

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(Serde<K> keySerde,
                               Serde<V> valSerde,
                               java.lang.String topic)

Deprecated.

Create a KTable for the specified topic. The default "auto.offset.reset" strategy as specified in the config is used. Input records with null key will be dropped.

Note that the specified input topics must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with an internal store name. Note that store name may not be queriable through Interactive Queries. No internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

Parameters:

keySerde - key serde used to send key-value pairs, if not specified the default key serde defined in the configuration will be used

valSerde - value serde used to send key-value pairs, if not specified the default value serde defined in the configuration will be used

topic - the topic name; cannot be null

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(TopologyBuilder.AutoOffsetReset offsetReset,
                               Serde<K> keySerde,
                               Serde<V> valSerde,
                               java.lang.String topic,
                               java.lang.String queryableStoreName)

Deprecated.

Create a KTable for the specified topic. Input records with null key will be dropped.

Note that the specified input topics must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with the given queryableStoreName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(queryableStoreName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key); // key must be local (application state is shared over all running Kafka Streams instances)
 

For non-local keys, a custom RPC mechanism must be implemented using KafkaStreams.allMetadata() to query the value of the key on a parallel running instance of your Kafka Streams application.

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the specified topic if no valid committed offsets are available

keySerde - key serde used to send key-value pairs, if not specified the default key serde defined in the configuration will be used

valSerde - value serde used to send key-value pairs, if not specified the default value serde defined in the configuration will be used

topic - the topic name; cannot be null

queryableStoreName - the state store name; If null this is the equivalent of table(AutoOffsetReset, Serde, Serde, String)

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(TimestampExtractor timestampExtractor,
                               Serde<K> keySerde,
                               Serde<V> valSerde,
                               java.lang.String topic,
                               java.lang.String storeName)

Deprecated.

Create a KTable for the specified topic. The default "auto.offset.reset" strategy as specified in the config is used. Input KeyValue pairs with null key will be dropped.

Note that the specified input topic must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with the given storeName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(storeName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key); // key must be local (application state is shared over all running Kafka Streams instances)
 

For non-local keys, a custom RPC mechanism must be implemented using KafkaStreams.allMetadata() to query the value of the key on a parallel running instance of your Kafka Streams application.

Parameters:

timestampExtractor - the stateless timestamp extractor used for this source KTable, if not specified the default extractor defined in the configs will be used

keySerde - key serde used to send key-value pairs, if not specified the default key serde defined in the configuration will be used

valSerde - value serde used to send key-value pairs, if not specified the default value serde defined in the configuration will be used

topic - the topic name; cannot be null

storeName - the state store name; cannot be null

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(TopologyBuilder.AutoOffsetReset offsetReset,
                               TimestampExtractor timestampExtractor,
                               Serde<K> keySerde,
                               Serde<V> valSerde,
                               java.lang.String topic,
                               java.lang.String queryableStoreName)

Deprecated.

Create a KTable for the specified topic. Input KeyValue pairs with null key will be dropped.

Note that the specified input topic must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with the given storeName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(storeName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key); // key must be local (application state is shared over all running Kafka Streams instances)
 

For non-local keys, a custom RPC mechanism must be implemented using KafkaStreams.allMetadata() to query the value of the key on a parallel running instance of your Kafka Streams application.

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the specified topic if no valid committed offsets are available

timestampExtractor - the stateless timestamp extractor used for this source KTable, if not specified the default extractor defined in the configs will be used

keySerde - key serde used to send key-value pairs, if not specified the default key serde defined in the configuration will be used

valSerde - value serde used to send key-value pairs, if not specified the default value serde defined in the configuration will be used

topic - the topic name; cannot be null

queryableStoreName - the state store name; If null this is the equivalent of table(AutoOffsetReset, Serde, Serde, String)

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(TopologyBuilder.AutoOffsetReset offsetReset,
                               Serde<K> keySerde,
                               Serde<V> valSerde,
                               java.lang.String topic)

Deprecated.

Create a KTable for the specified topic. The default "auto.offset.reset" strategy as specified in the config is used. Input records with null key will be dropped.

Note that the specified input topics must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with an internal store name. Note that store name may not be queriable through Interactive Queries. No internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the specified topic if no valid committed offsets are available

keySerde - key serde used to send key-value pairs, if not specified the default key serde defined in the configuration will be used

valSerde - value serde used to send key-value pairs, if not specified the default value serde defined in the configuration will be used

topic - the topic name; cannot be null

Returns:

a KTable for the specified topic

table

public <K,V> KTable<K,V> table(TopologyBuilder.AutoOffsetReset offsetReset,
                               TimestampExtractor timestampExtractor,
                               Serde<K> keySerde,
                               Serde<V> valSerde,
                               java.lang.String topic,
                               StateStoreSupplier<KeyValueStore> storeSupplier)

Deprecated.

Create a KTable for the specified topic. Input records with null key will be dropped.

Note that the specified input topics must be partitioned by key. If this is not the case the returned KTable will be corrupted.

The resulting KTable will be materialized in a local KeyValueStore with the given queryableStoreName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(queryableStoreName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key); // key must be local (application state is shared over all running Kafka Streams instances)
 

For non-local keys, a custom RPC mechanism must be implemented using KafkaStreams.allMetadata() to query the value of the key on a parallel running instance of your Kafka Streams application.

Parameters:

offsetReset - the "auto.offset.reset" policy to use for the specified topic if no valid committed offsets are available

keySerde - key serde used to send key-value pairs, if not specified the default key serde defined in the configuration will be used

valSerde - value serde used to send key-value pairs, if not specified the default value serde defined in the configuration will be used

topic - the topic name; cannot be null

storeSupplier - user defined state store supplier. Cannot be null.

Returns:

a KTable for the specified topic

globalTable

public <K,V> GlobalKTable<K,V> globalTable(java.lang.String topic,
                                           java.lang.String queryableStoreName)

Deprecated.

Create a GlobalKTable for the specified topic. The default key and value deserializers as specified in the config are used. Input records with null key will be dropped.

The resulting GlobalKTable will be materialized in a local KeyValueStore with the given queryableStoreName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(queryableStoreName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key);
 

Note that GlobalKTable always applies "auto.offset.reset" strategy "earliest" regardless of the specified value in StreamsConfig.

Parameters:

topic - the topic name; cannot be null

queryableStoreName - the state store name; If null this is the equivalent of globalTable(String)

Returns:

a GlobalKTable for the specified topic

globalTable

public <K,V> GlobalKTable<K,V> globalTable(java.lang.String topic)

Deprecated.

Create a GlobalKTable for the specified topic. The default key and value deserializers as specified in the config are used. Input records with null key will be dropped.

The resulting GlobalKTable will be materialized in a local KeyValueStore with an internal store name. Note that store name may not be queriable through Interactive Queries. No internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

Note that GlobalKTable always applies "auto.offset.reset" strategy "earliest" regardless of the specified value in StreamsConfig.

Parameters:

topic - the topic name; cannot be null

Returns:

a GlobalKTable for the specified topic

globalTable

public <K,V> GlobalKTable<K,V> globalTable(Serde<K> keySerde,
                                           Serde<V> valSerde,
                                           TimestampExtractor timestampExtractor,
                                           java.lang.String topic,
                                           java.lang.String queryableStoreName)

Deprecated.

Create a GlobalKTable for the specified topic. The default TimestampExtractor and default key and value deserializers as specified in the config are used. Input KeyValue pairs with null key will be dropped.

The resulting GlobalKTable will be materialized in a local KeyValueStore with the given queryableStoreName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(queryableStoreName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key);
 

Note that GlobalKTable always applies "auto.offset.reset" strategy "earliest" regardless of the specified value in StreamsConfig.

Parameters:

keySerde - key serde used to send key-value pairs, if not specified the default key serde defined in the configuration will be used

valSerde - value serde used to send key-value pairs, if not specified the default value serde defined in the configuration will be used

topic - the topic name; cannot be null

queryableStoreName - the state store name; If null this is the equivalent of globalTable(Serde, Serde, String) ()}

Returns:

a GlobalKTable for the specified topic

globalTable

public <K,V> GlobalKTable<K,V> globalTable(Serde<K> keySerde,
                                           Serde<V> valSerde,
                                           java.lang.String topic,
                                           StateStoreSupplier<KeyValueStore> storeSupplier)

Deprecated.

Create a GlobalKTable for the specified topic. The default TimestampExtractor as specified in the config is used. Input KeyValue pairs with null key will be dropped.

The resulting GlobalKTable will be materialized in a local KeyValueStore with the given queryableStoreName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(queryableStoreName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key);
 

Note that GlobalKTable always applies "auto.offset.reset" strategy "earliest" regardless of the specified value in StreamsConfig.

Parameters:

keySerde - key serde used to send key-value pairs, if not specified the default key serde defined in the configuration will be used

valSerde - value serde used to send key-value pairs, if not specified the default value serde defined in the configuration will be used

topic - the topic name; cannot be null

storeSupplier - user defined state store supplier. Cannot be null.

Returns:

a GlobalKTable for the specified topic

globalTable

public <K,V> GlobalKTable<K,V> globalTable(Serde<K> keySerde,
                                           Serde<V> valSerde,
                                           java.lang.String topic,
                                           java.lang.String queryableStoreName)

Deprecated.

Create a GlobalKTable for the specified topic. The default TimestampExtractor as specified in the config is used. Input KeyValue pairs with null key will be dropped.

The resulting GlobalKTable will be materialized in a local KeyValueStore with the given queryableStoreName. However, no internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

To query the local KeyValueStore it must be obtained via KafkaStreams#store(...):

 KafkaStreams streams = ...
 ReadOnlyKeyValueStore<String, Long> localStore = streams.store(queryableStoreName, QueryableStoreTypes.<String, Long>keyValueStore());
 String key = "some-key";
 Long valueForKey = localStore.get(key);
 

Note that GlobalKTable always applies "auto.offset.reset" strategy "earliest" regardless of the specified value in StreamsConfig.

Parameters:

keySerde - key serde used to send key-value pairs, if not specified the default key serde defined in the configuration will be used

valSerde - value serde used to send key-value pairs, if not specified the default value serde defined in the configuration will be used

topic - the topic name; cannot be null

queryableStoreName - the state store name; If null this is the equivalent of globalTable(Serde, Serde, String) ()}

Returns:

a GlobalKTable for the specified topic

globalTable

public <K,V> GlobalKTable<K,V> globalTable(Serde<K> keySerde,
                                           Serde<V> valSerde,
                                           java.lang.String topic)

Deprecated.

Create a GlobalKTable for the specified topic. The default key and value deserializers as specified in the config are used. Input records with null key will be dropped.

The resulting GlobalKTable will be materialized in a local KeyValueStore with an internal store name. Note that store name may not be queriable through Interactive Queries. No internal changelog topic is created since the original input topic can be used for recovery (cf. methods of KGroupedStream and KGroupedTable that return a KTable).

Note that GlobalKTable always applies "auto.offset.reset" strategy "earliest" regardless of the specified value in StreamsConfig.

Parameters:

keySerde - key serde used to send key-value pairs, if not specified the default key serde defined in the configuration will be used

valSerde - value serde used to send key-value pairs, if not specified the default value serde defined in the configuration will be used

topic - the topic name; cannot be null

Returns:

a GlobalKTable for the specified topic

merge

public <K,V> KStream<K,V> merge(KStream<K,V>... streams)

Deprecated.

Create a new instance of KStream by merging the given KStreams.

There is no ordering guarantee for records from different KStreams.

Parameters:

streams - the KStreams to be merged

Returns:

a KStream containing all records of the given streams

newName

public java.lang.String newName(java.lang.String prefix)

Deprecated.

This function is only for internal usage only and should not be called.

Create a unique processor name used for translation into the processor topology.

Parameters:

prefix - processor name prefix

Returns:

a new unique name

newStoreName

public java.lang.String newStoreName(java.lang.String prefix)

Deprecated.

This function is only for internal usage only and should not be called.

Create a unique state store name.

Parameters:

prefix - processor name prefix

Returns:

a new unique name