Type Parameters:: K - type of keys; V - type of values

All Superinterfaces:: org.apache.kafka.streams.kstream.KStream<K,V>

public interface KStreamX<K,V> extends org.apache.kafka.streams.kstream.KStream<K,V>

Extends the KStream interface by adding methods to simplify Serde configuration, error handling, and topic access

Method Summary

Modifier and Type

Method

Description

KStreamX<K,V>

filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate)

KStreamX<K,V>

filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Named named)

KStreamX<K,V>

filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate)

KStreamX<K,V>

filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Named named)

<KR, VR> KStreamX<KR,VR>

flatMap(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends Iterable<? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>>> mapper)

<KR, VR> KStreamX<KR,VR>

flatMap(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends Iterable<? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>>> mapper, org.apache.kafka.streams.kstream.Named named)

<KR, VR> KErrorStreamX<K,V,KR,VR>

flatMapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends Iterable<? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>>> mapper)

Transform each record of the input stream into zero or more records in the output stream.

<KR, VR> KErrorStreamX<K,V,KR,VR>

flatMapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends Iterable<? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>>> mapper, Predicate<Exception> errorFilter)

Transform each record of the input stream into zero or more records in the output stream.

<KR, VR> KErrorStreamX<K,V,KR,VR>

flatMapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends Iterable<? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>>> mapper, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named)

Transform each record of the input stream into zero or more records in the output stream.

<KR, VR> KErrorStreamX<K,V,KR,VR>

flatMapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends Iterable<? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>>> mapper, org.apache.kafka.streams.kstream.Named named)

Transform each record of the input stream into zero or more records in the output stream.

<VR> KStreamX<K,VR>

flatMapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends Iterable<? extends VR>> mapper)

<VR> KStreamX<K,VR>

flatMapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends Iterable<? extends VR>> mapper, org.apache.kafka.streams.kstream.Named named)

<VR> KStreamX<K,VR>

flatMapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends Iterable<? extends VR>> mapper)

<VR> KStreamX<K,VR>

flatMapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends Iterable<? extends VR>> mapper, org.apache.kafka.streams.kstream.Named named)

<VR> KErrorStreamX<K,V,K,VR>

flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends Iterable<? extends VR>> mapper)

Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream.

<VR> KErrorStreamX<K,V,K,VR>

flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends Iterable<? extends VR>> mapper, Predicate<Exception> errorFilter)

Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream.

<VR> KErrorStreamX<K,V,K,VR>

flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends Iterable<? extends VR>> mapper, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named)

Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream.

<VR> KErrorStreamX<K,V,K,VR>

flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends Iterable<? extends VR>> mapper, org.apache.kafka.streams.kstream.Named named)

Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream.

<VR> KErrorStreamX<K,V,K,VR>

flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends Iterable<? extends VR>> mapper)

Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream.

<VR> KErrorStreamX<K,V,K,VR>

flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends Iterable<? extends VR>> mapper, Predicate<Exception> errorFilter)

Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream.

<VR> KErrorStreamX<K,V,K,VR>

flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends Iterable<? extends VR>> mapper, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named)

Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream.

<VR> KErrorStreamX<K,V,K,VR>

flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends Iterable<? extends VR>> mapper, org.apache.kafka.streams.kstream.Named named)

Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream.

<KR> KGroupedStreamX<KR,V>

groupBy(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,KR> keySelector)

<KR> KGroupedStreamX<KR,V>

groupBy(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,KR> keySelector, GroupedX<KR,V> grouped)

<KR> KGroupedStreamX<KR,V>

groupBy(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,KR> keySelector, org.apache.kafka.streams.kstream.Grouped<KR,V> grouped)

KGroupedStreamX<K,V>

groupByKey()

KGroupedStreamX<K,V>

groupByKey(GroupedX<K,V> grouped)

KGroupedStreamX<K,V>

groupByKey(org.apache.kafka.streams.kstream.Grouped<K,V> grouped)

<GK, GV, RV> KStreamX<K,RV>

join(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super GV,? extends RV> joiner)

<GK, GV, RV> KStreamX<K,RV>

join(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super GV,? extends RV> joiner, org.apache.kafka.streams.kstream.Named named)

<GK, GV, RV> KStreamX<K,RV>

join(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super GV,? extends RV> joiner)

<GK, GV, RV> KStreamX<K,RV>

join(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super GV,? extends RV> joiner, org.apache.kafka.streams.kstream.Named named)

<VO, VR> KStreamX<K,VR>

join(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows)

<VO, VR> KStreamX<K,VR>

join(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, StreamJoinedX<K,V,VO> streamJoined)

<VO, VR> KStreamX<K,VR>

join(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, org.apache.kafka.streams.kstream.StreamJoined<K,V,VO> streamJoined)

<VO, VR> KStreamX<K,VR>

join(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows)

<VO, VR> KStreamX<K,VR>

join(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, StreamJoinedX<K,V,VO> streamJoined)

<VO, VR> KStreamX<K,VR>

join(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, org.apache.kafka.streams.kstream.StreamJoined<K,V,VO> streamJoined)

<VT, VR> KStreamX<K,VR>

join(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VT,? extends VR> joiner)

<VT, VR> KStreamX<K,VR>

join(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VT,? extends VR> joiner, JoinedX<K,V,VT> joined)

<VT, VR> KStreamX<K,VR>

join(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VT,? extends VR> joiner, org.apache.kafka.streams.kstream.Joined<K,V,VT> joined)

<VT, VR> KStreamX<K,VR>

join(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VT,? extends VR> joiner)

<VT, VR> KStreamX<K,VR>

join(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VT,? extends VR> joiner, JoinedX<K,V,VT> joined)

<VT, VR> KStreamX<K,VR>

join(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VT,? extends VR> joiner, org.apache.kafka.streams.kstream.Joined<K,V,VT> joined)

<GK, GV, RV> KStreamX<K,RV>

leftJoin(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super GV,? extends RV> valueJoiner)

<GK, GV, RV> KStreamX<K,RV>

leftJoin(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super GV,? extends RV> valueJoiner, org.apache.kafka.streams.kstream.Named named)

<GK, GV, RV> KStreamX<K,RV>

leftJoin(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super GV,? extends RV> valueJoiner)

<GK, GV, RV> KStreamX<K,RV>

leftJoin(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super GV,? extends RV> valueJoiner, org.apache.kafka.streams.kstream.Named named)

<VO, VR> KStreamX<K,VR>

leftJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows)

<VO, VR> KStreamX<K,VR>

leftJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, StreamJoinedX<K,V,VO> streamJoined)

<VO, VR> KStreamX<K,VR>

leftJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, org.apache.kafka.streams.kstream.StreamJoined<K,V,VO> streamJoined)

<VO, VR> KStreamX<K,VR>

leftJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows)

<VO, VR> KStreamX<K,VR>

leftJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, StreamJoinedX<K,V,VO> streamJoined)

<VO, VR> KStreamX<K,VR>

leftJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, org.apache.kafka.streams.kstream.StreamJoined<K,V,VO> streamJoined)

<VT, VR> KStreamX<K,VR>

leftJoin(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VT,? extends VR> joiner)

<VT, VR> KStreamX<K,VR>

leftJoin(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VT,? extends VR> joiner, JoinedX<K,V,VT> joined)

<VT, VR> KStreamX<K,VR>

leftJoin(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VT,? extends VR> joiner, org.apache.kafka.streams.kstream.Joined<K,V,VT> joined)

<VT, VR> KStreamX<K,VR>

leftJoin(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VT,? extends VR> joiner)

<VT, VR> KStreamX<K,VR>

leftJoin(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VT,? extends VR> joiner, JoinedX<K,V,VT> joined)

<VT, VR> KStreamX<K,VR>

leftJoin(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VT,? extends VR> joiner, org.apache.kafka.streams.kstream.Joined<K,V,VT> joined)

<KR, VR> KStreamX<KR,VR>

map(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>> mapper)

<KR, VR> KStreamX<KR,VR>

map(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>> mapper, org.apache.kafka.streams.kstream.Named named)

<KR, VR> KErrorStreamX<K,V,KR,VR>

mapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>> mapper)

Transform each record of the input stream into a new record in the output stream.

<KR, VR> KErrorStreamX<K,V,KR,VR>

mapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>> mapper, Predicate<Exception> errorFilter)

Transform each record of the input stream into a new record in the output stream.

<KR, VR> KErrorStreamX<K,V,KR,VR>

mapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>> mapper, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named)

Transform each record of the input stream into a new record in the output stream.

<KR, VR> KErrorStreamX<K,V,KR,VR>

mapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>> mapper, org.apache.kafka.streams.kstream.Named named)

Transform each record of the input stream into a new record in the output stream.

<VR> KStreamX<K,VR>

mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper)

<VR> KStreamX<K,VR>

mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named)

<VR> KStreamX<K,VR>

mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper)

<VR> KStreamX<K,VR>

mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named)

<VR> KErrorStreamX<K,V,K,VR>

mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper)

Transform the value of each input record into a new value of the output record.

<VR> KErrorStreamX<K,V,K,VR>

mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, Predicate<Exception> errorFilter)

Transform the value of each input record into a new value of the output record.

<VR> KErrorStreamX<K,V,K,VR>

mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named)

Transform the value of each input record into a new value of the output record.

<VR> KErrorStreamX<K,V,K,VR>

mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named)

Transform the value of each input record into a new value of the output record.

<VR> KErrorStreamX<K,V,K,VR>

mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper)

Transform the value of each input record into a new value of the output record.

<VR> KErrorStreamX<K,V,K,VR>

mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, Predicate<Exception> errorFilter)

Transform the value of each input record into a new value of the output record.

<VR> KErrorStreamX<K,V,K,VR>

mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named)

Transform the value of each input record into a new value of the output record.

<VR> KErrorStreamX<K,V,K,VR>

mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named)

Transform the value of each input record into a new value of the output record.

KStreamX<K,V>

merge(org.apache.kafka.streams.kstream.KStream<K,V> stream)

KStreamX<K,V>

merge(org.apache.kafka.streams.kstream.KStream<K,V> stream, org.apache.kafka.streams.kstream.Named named)

<VO, VR> KStreamX<K,VR>

outerJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows)

<VO, VR> KStreamX<K,VR>

outerJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, StreamJoinedX<K,V,VO> streamJoined)

<VO, VR> KStreamX<K,VR>

outerJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, org.apache.kafka.streams.kstream.StreamJoined<K,V,VO> streamJoined)

<VO, VR> KStreamX<K,VR>

outerJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows)

<VO, VR> KStreamX<K,VR>

outerJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, StreamJoinedX<K,V,VO> streamJoined)

<VO, VR> KStreamX<K,VR>

outerJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, org.apache.kafka.streams.kstream.StreamJoined<K,V,VO> streamJoined)

KStreamX<K,V>

peek(org.apache.kafka.streams.kstream.ForeachAction<? super K,? super V> action)

KStreamX<K,V>

peek(org.apache.kafka.streams.kstream.ForeachAction<? super K,? super V> action, org.apache.kafka.streams.kstream.Named named)

<KOut, VOut> KStreamX<KOut,VOut>

process(org.apache.kafka.streams.processor.api.ProcessorSupplier<? super K,? super V,KOut,VOut> processorSupplier, String... stateStoreNames)

<KOut, VOut> KStreamX<KOut,VOut>

process(org.apache.kafka.streams.processor.api.ProcessorSupplier<? super K,? super V,KOut,VOut> processorSupplier, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)

<KOut, VOut> KErrorStreamX<K,V,KOut,VOut>

processCapturingErrors(org.apache.kafka.streams.processor.api.ProcessorSupplier<? super K,? super V,KOut,VOut> processorSupplier, String... stateStoreNames)

Process all records in this stream, one record at a time, by applying a Processor.

<KOut, VOut> KErrorStreamX<K,V,KOut,VOut>

processCapturingErrors(org.apache.kafka.streams.processor.api.ProcessorSupplier<? super K,? super V,KOut,VOut> processorSupplier, Predicate<Exception> errorFilter, String... stateStoreNames)

Process all records in this stream, one record at a time, by applying a Processor.

<KOut, VOut> KErrorStreamX<K,V,KOut,VOut>

processCapturingErrors(org.apache.kafka.streams.processor.api.ProcessorSupplier<? super K,? super V,KOut,VOut> processorSupplier, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)

Process all records in this stream, one record at a time, by applying a Processor.

<KOut, VOut> KErrorStreamX<K,V,KOut,VOut>

processCapturingErrors(org.apache.kafka.streams.processor.api.ProcessorSupplier<? super K,? super V,KOut,VOut> processorSupplier, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)

Process all records in this stream, one record at a time, by applying a Processor.

<VOut> KStreamX<K,VOut>

processValues(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<? super K,? super V,VOut> processorSupplier, String... stateStoreNames)

<VOut> KStreamX<K,VOut>

processValues(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<? super K,? super V,VOut> processorSupplier, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)

<VOut> KErrorStreamX<K,V,K,VOut>

processValuesCapturingErrors(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<? super K,? super V,VOut> processorSupplier, String... stateStoreNames)

Process all records in this stream, one record at a time, by applying a FixedKeyProcessor.

<VOut> KErrorStreamX<K,V,K,VOut>

processValuesCapturingErrors(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<? super K,? super V,VOut> processorSupplier, Predicate<Exception> errorFilter, String... stateStoreNames)

Process all records in this stream, one record at a time, by applying a FixedKeyProcessor.

<VOut> KErrorStreamX<K,V,K,VOut>

processValuesCapturingErrors(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<? super K,? super V,VOut> processorSupplier, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)

Process all records in this stream, one record at a time, by applying a FixedKeyProcessor.

<VOut> KErrorStreamX<K,V,K,VOut>

processValuesCapturingErrors(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<? super K,? super V,VOut> processorSupplier, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)

Process all records in this stream, one record at a time, by applying a FixedKeyProcessor.

KStreamX<K,V>

repartition()

KStreamX<K,V>

repartition(RepartitionedX<K,V> repartitioned)

KStreamX<K,V>

repartition(org.apache.kafka.streams.kstream.Repartitioned<K,V> repartitioned)

<KR> KStreamX<KR,V>

selectKey(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends KR> mapper)

<KR> KStreamX<KR,V>

selectKey(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends KR> mapper, org.apache.kafka.streams.kstream.Named named)

BranchedKStreamX<K,V>

split()

BranchedKStreamX<K,V>

split(org.apache.kafka.streams.kstream.Named named)

void

to(String topic, ProducedX<K,V> produced)

void

to(org.apache.kafka.streams.processor.TopicNameExtractor<K,V> topicExtractor, ProducedX<K,V> produced)

void

toErrorTopic()

Materialize KStream to StreamsTopicConfig.getErrorTopic()

void

toErrorTopic(ProducedX<K,V> produced)

Materialize KStream to StreamsTopicConfig.getErrorTopic()

void

toErrorTopic(org.apache.kafka.streams.kstream.Produced<K,V> produced)

Materialize KStream to StreamsTopicConfig.getErrorTopic()

void

toOutputTopic()

Materialize KStream to StreamsTopicConfig.getOutputTopic()

void

toOutputTopic(ProducedX<K,V> produced)

Materialize KStream to StreamsTopicConfig.getOutputTopic()

void

toOutputTopic(String label)

Materialize KStream to StreamsTopicConfig.getOutputTopic(String)

void

toOutputTopic(String label, ProducedX<K,V> produced)

Materialize KStream to StreamsTopicConfig.getOutputTopic(String)

void

toOutputTopic(String label, org.apache.kafka.streams.kstream.Produced<K,V> produced)

Materialize KStream to StreamsTopicConfig.getOutputTopic(String)

void

toOutputTopic(org.apache.kafka.streams.kstream.Produced<K,V> produced)

Materialize KStream to StreamsTopicConfig.getOutputTopic()

KTableX<K,V>

toTable()

KTableX<K,V>

toTable(MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

KTableX<K,V>

toTable(org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

KTableX<K,V>

toTable(org.apache.kafka.streams.kstream.Named named)

KTableX<K,V>

toTable(org.apache.kafka.streams.kstream.Named named, MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

KTableX<K,V>

toTable(org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)

Methods inherited from interface org.apache.kafka.streams.kstream.KStream
foreach, foreach, print, to, to, to, to

Method Details
- filter
  
  KStreamX<K,V> filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate)
  
  Specified by:
  
  filter in interface org.apache.kafka.streams.kstream.KStream<K,V>
- filter
  
  KStreamX<K,V> filter(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  filter in interface org.apache.kafka.streams.kstream.KStream<K,V>
- filterNot
  
  KStreamX<K,V> filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate)
  
  Specified by:
  
  filterNot in interface org.apache.kafka.streams.kstream.KStream<K,V>
- filterNot
  
  KStreamX<K,V> filterNot(org.apache.kafka.streams.kstream.Predicate<? super K,? super V> predicate, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  filterNot in interface org.apache.kafka.streams.kstream.KStream<K,V>
- selectKey
  
  <KR> KStreamX<KR,V> selectKey(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends KR> mapper)
  
  Specified by:
  
  selectKey in interface org.apache.kafka.streams.kstream.KStream<K,V>
- selectKey
  
  <KR> KStreamX<KR,V> selectKey(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends KR> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  selectKey in interface org.apache.kafka.streams.kstream.KStream<K,V>
- map
  
  <KR, VR> KStreamX<KR,VR> map(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>> mapper)
  
  Specified by:
  
  map in interface org.apache.kafka.streams.kstream.KStream<K,V>
- mapCapturingErrors
  
  <KR, VR> KErrorStreamX<K,V,KR,VR> mapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>> mapper)
  
  Transform each record of the input stream into a new record in the output stream. Errors in the mapper are captured
  Type Parameters:
  
  KR - the key type of the result stream
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a KeyValueMapper that computes a new output record
  
  Returns:
  
  a KErrorStreamX that contains records with new key and value as well as captured errors
  
  See Also:
  
  map(KeyValueMapper)
  
  ErrorCapturingKeyValueMapper.captureErrors(KeyValueMapper)
- mapCapturingErrors
  
  <KR, VR> KErrorStreamX<K,V,KR,VR> mapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>> mapper, Predicate<Exception> errorFilter)
  
  Transform each record of the input stream into a new record in the output stream. Errors in the mapper are captured
  Type Parameters:
  
  KR - the key type of the result stream
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a KeyValueMapper that computes a new output record
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  Returns:
  
  a KErrorStreamX that contains records with new key and value as well as captured errors
  
  See Also:
  
  map(KeyValueMapper)
  
  ErrorCapturingKeyValueMapper.captureErrors(KeyValueMapper, java.util.function.Predicate)
- map
  
  <KR, VR> KStreamX<KR,VR> map(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  map in interface org.apache.kafka.streams.kstream.KStream<K,V>
- mapCapturingErrors
  
  <KR, VR> KErrorStreamX<K,V,KR,VR> mapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Transform each record of the input stream into a new record in the output stream. Errors in the mapper are captured
  Type Parameters:
  
  KR - the key type of the result stream
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a KeyValueMapper that computes a new output record
  
  named - a Named config used to name the processor in the topology
  
  Returns:
  
  a KErrorStreamX that contains records with new key and value as well as captured errors
  
  See Also:
  
  map(KeyValueMapper, Named)
  
  ErrorCapturingKeyValueMapper.captureErrors(KeyValueMapper)
- mapCapturingErrors
  
  <KR, VR> KErrorStreamX<K,V,KR,VR> mapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>> mapper, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named)
  
  Transform each record of the input stream into a new record in the output stream. Errors in the mapper are captured
  Type Parameters:
  
  KR - the key type of the result stream
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a KeyValueMapper that computes a new output record
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  named - a Named config used to name the processor in the topology
  
  Returns:
  
  a KErrorStreamX that contains records with new key and value as well as captured errors
  
  See Also:
  
  map(KeyValueMapper, Named)
  
  ErrorCapturingKeyValueMapper.captureErrors(KeyValueMapper, java.util.function.Predicate)
- mapValues
  
  <VR> KStreamX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper)
  
  Specified by:
  
  mapValues in interface org.apache.kafka.streams.kstream.KStream<K,V>
- mapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper)
  
  Transform the value of each input record into a new value of the output record. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapper that computes a new output value
  
  Returns:
  
  a KErrorStreamX that contains records with unmodified key and new values as well as captured errors
  
  See Also:
  
  mapValues(ValueMapper)
  
  ErrorCapturingValueMapper.captureErrors(ValueMapper)
- mapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, Predicate<Exception> errorFilter)
  
  Transform the value of each input record into a new value of the output record. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapper that computes a new output value
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  Returns:
  
  a KErrorStreamX that contains records with unmodified key and new values as well as captured errors
  
  See Also:
  
  mapValues(ValueMapper)
  
  ErrorCapturingValueMapper.captureErrors(ValueMapper, java.util.function.Predicate)
- mapValues
  
  <VR> KStreamX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  mapValues in interface org.apache.kafka.streams.kstream.KStream<K,V>
- mapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Transform the value of each input record into a new value of the output record. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapper that computes a new output value
  
  named - a Named config used to name the processor in the topology
  
  Returns:
  
  a KErrorStreamX that contains records with unmodified key and new values as well as captured errors
  
  See Also:
  
  mapValues(ValueMapper, Named)
  
  ErrorCapturingValueMapper.captureErrors(ValueMapper)
- mapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends VR> mapper, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named)
  
  Transform the value of each input record into a new value of the output record. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapper that computes a new output value
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  named - a Named config used to name the processor in the topology
  
  Returns:
  
  a KErrorStreamX that contains records with unmodified key and new values as well as captured errors
  
  See Also:
  
  mapValues(ValueMapper, Named)
  
  ErrorCapturingValueMapper.captureErrors(ValueMapper, java.util.function.Predicate)
- mapValues
  
  <VR> KStreamX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper)
  
  Specified by:
  
  mapValues in interface org.apache.kafka.streams.kstream.KStream<K,V>
- mapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper)
  
  Transform the value of each input record into a new value of the output record. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapperWithKey that computes a new output value
  
  Returns:
  
  a KErrorStreamX that contains records with unmodified key and new values as well as captured errors
  
  See Also:
  
  mapValues(ValueMapperWithKey)
  
  ErrorCapturingValueMapperWithKey.captureErrors(ValueMapperWithKey)
- mapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, Predicate<Exception> errorFilter)
  
  Transform the value of each input record into a new value of the output record. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapperWithKey that computes a new output value
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  Returns:
  
  a KErrorStreamX that contains records with unmodified key and new values as well as captured errors
  
  See Also:
  
  mapValues(ValueMapperWithKey)
  
  ErrorCapturingValueMapperWithKey.captureErrors(ValueMapperWithKey, java.util.function.Predicate)
- mapValues
  
  <VR> KStreamX<K,VR> mapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  mapValues in interface org.apache.kafka.streams.kstream.KStream<K,V>
- mapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Transform the value of each input record into a new value of the output record. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapperWithKey that computes a new output value
  
  named - a Named config used to name the processor in the topology
  
  Returns:
  
  a KErrorStreamX that contains records with unmodified key and new values as well as captured errors
  
  See Also:
  
  mapValues(ValueMapperWithKey, Named)
  
  ErrorCapturingValueMapperWithKey.captureErrors(ValueMapperWithKey)
- mapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> mapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends VR> mapper, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named)
  
  Transform the value of each input record into a new value of the output record. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapperWithKey that computes a new output value
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  named - a Named config used to name the processor in the topology
  
  Returns:
  
  a KErrorStreamX that contains records with unmodified key and new values as well as captured errors
  
  See Also:
  
  mapValues(ValueMapperWithKey, Named)
  
  ErrorCapturingValueMapperWithKey.captureErrors(ValueMapperWithKey, java.util.function.Predicate)
- flatMap
  
  <KR, VR> KStreamX<KR,VR> flatMap(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends Iterable<? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>>> mapper)
  
  Specified by:
  
  flatMap in interface org.apache.kafka.streams.kstream.KStream<K,V>
- flatMapCapturingErrors
  
  <KR, VR> KErrorStreamX<K,V,KR,VR> flatMapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends Iterable<? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>>> mapper)
  
  Transform each record of the input stream into zero or more records in the output stream. Errors in the mapper are captured
  Type Parameters:
  
  KR - the key type of the result stream
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a KeyValueMapper that computes the new output records
  
  Returns:
  
  a KErrorStreamX that contains more or less records with new key and value as well as captured errors
  
  See Also:
  
  flatMap(KeyValueMapper)
  
  ErrorCapturingFlatKeyValueMapper.captureErrors(KeyValueMapper)
- flatMapCapturingErrors
  
  <KR, VR> KErrorStreamX<K,V,KR,VR> flatMapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends Iterable<? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>>> mapper, Predicate<Exception> errorFilter)
  
  Transform each record of the input stream into zero or more records in the output stream. Errors in the mapper are captured
  Type Parameters:
  
  KR - the key type of the result stream
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a KeyValueMapper that computes the new output records
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  Returns:
  
  a KErrorStreamX that contains more or less records with new key and value as well as captured errors
  
  See Also:
  
  flatMap(KeyValueMapper)
  
  ErrorCapturingFlatKeyValueMapper.captureErrors(KeyValueMapper, java.util.function.Predicate)
- flatMap
  
  <KR, VR> KStreamX<KR,VR> flatMap(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends Iterable<? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>>> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  flatMap in interface org.apache.kafka.streams.kstream.KStream<K,V>
- flatMapCapturingErrors
  
  <KR, VR> KErrorStreamX<K,V,KR,VR> flatMapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends Iterable<? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>>> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Transform each record of the input stream into zero or more records in the output stream. Errors in the mapper are captured
  Type Parameters:
  
  KR - the key type of the result stream
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a KeyValueMapper that computes the new output records
  
  named - a Named config used to name the processor in the topology
  
  Returns:
  
  a KErrorStreamX that contains more or less records with new key and value as well as captured errors
  
  See Also:
  
  flatMap(KeyValueMapper, Named)
  
  ErrorCapturingFlatKeyValueMapper.captureErrors(KeyValueMapper)
- flatMapCapturingErrors
  
  <KR, VR> KErrorStreamX<K,V,KR,VR> flatMapCapturingErrors(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends Iterable<? extends org.apache.kafka.streams.KeyValue<? extends KR,? extends VR>>> mapper, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named)
  
  Transform each record of the input stream into zero or more records in the output stream. Errors in the mapper are captured
  Type Parameters:
  
  KR - the key type of the result stream
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a KeyValueMapper that computes the new output records
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  named - a Named config used to name the processor in the topology
  
  Returns:
  
  a KErrorStreamX that contains more or less records with new key and value as well as captured errors
  
  See Also:
  
  flatMap(KeyValueMapper, Named)
  
  ErrorCapturingFlatKeyValueMapper.captureErrors(KeyValueMapper, java.util.function.Predicate)
- flatMapValues
  
  <VR> KStreamX<K,VR> flatMapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends Iterable<? extends VR>> mapper)
  
  Specified by:
  
  flatMapValues in interface org.apache.kafka.streams.kstream.KStream<K,V>
- flatMapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends Iterable<? extends VR>> mapper)
  
  Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapper that computes the new output values
  
  Returns:
  
  a KErrorStreamX that contains more or less records with unmodified keys and new values as well as captured errors
  
  See Also:
  
  flatMapValues(ValueMapper)
  
  ErrorCapturingFlatValueMapper.captureErrors(ValueMapper)
- flatMapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends Iterable<? extends VR>> mapper, Predicate<Exception> errorFilter)
  
  Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapper that computes the new output values
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  Returns:
  
  a KErrorStreamX that contains more or less records with unmodified keys and new values as well as captured errors
  
  See Also:
  
  flatMapValues(ValueMapper)
  
  ErrorCapturingFlatValueMapper.captureErrors(ValueMapper, java.util.function.Predicate)
- flatMapValues
  
  <VR> KStreamX<K,VR> flatMapValues(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends Iterable<? extends VR>> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  flatMapValues in interface org.apache.kafka.streams.kstream.KStream<K,V>
- flatMapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends Iterable<? extends VR>> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapper that computes the new output values
  
  named - a Named config used to name the processor in the topology
  
  Returns:
  
  a KErrorStreamX that contains more or less records with unmodified keys and new values as well as captured errors
  
  See Also:
  
  flatMapValues(ValueMapper, Named)
  
  ErrorCapturingFlatValueMapper.captureErrors(ValueMapper)
- flatMapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapper<? super V,? extends Iterable<? extends VR>> mapper, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named)
  
  Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapper that computes the new output values
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  named - a Named config used to name the processor in the topology
  
  Returns:
  
  a KErrorStreamX that contains more or less records with unmodified keys and new values as well as captured errors
  
  See Also:
  
  flatMapValues(ValueMapper, Named)
  
  ErrorCapturingFlatValueMapper.captureErrors(ValueMapper, java.util.function.Predicate)
- flatMapValues
  
  <VR> KStreamX<K,VR> flatMapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends Iterable<? extends VR>> mapper)
  
  Specified by:
  
  flatMapValues in interface org.apache.kafka.streams.kstream.KStream<K,V>
- flatMapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends Iterable<? extends VR>> mapper)
  
  Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapperWithKey that computes the new output values
  
  Returns:
  
  a KErrorStreamX that contains more or less records with unmodified keys and new values as well as captured errors
  
  See Also:
  
  flatMapValues(ValueMapperWithKey)
  
  ErrorCapturingFlatValueMapperWithKey.captureErrors(ValueMapperWithKey)
- flatMapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends Iterable<? extends VR>> mapper, Predicate<Exception> errorFilter)
  
  Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapperWithKey that computes the new output values
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  Returns:
  
  a KErrorStreamX that contains more or less records with unmodified keys and new values as well as captured errors
  
  See Also:
  
  flatMapValues(ValueMapperWithKey)
  
  ErrorCapturingFlatValueMapperWithKey.captureErrors(ValueMapperWithKey, java.util.function.Predicate)
- flatMapValues
  
  <VR> KStreamX<K,VR> flatMapValues(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends Iterable<? extends VR>> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  flatMapValues in interface org.apache.kafka.streams.kstream.KStream<K,V>
- flatMapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends Iterable<? extends VR>> mapper, org.apache.kafka.streams.kstream.Named named)
  
  Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapperWithKey that computes the new output values
  
  named - a Named config used to name the processor in the topology
  
  Returns:
  
  a KErrorStreamX that contains more or less records with unmodified keys and new values as well as captured errors
  
  See Also:
  
  flatMapValues(ValueMapperWithKey, Named)
  
  ErrorCapturingFlatValueMapperWithKey.captureErrors(ValueMapperWithKey)
- flatMapValuesCapturingErrors
  
  <VR> KErrorStreamX<K,V,K,VR> flatMapValuesCapturingErrors(org.apache.kafka.streams.kstream.ValueMapperWithKey<? super K,? super V,? extends Iterable<? extends VR>> mapper, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named)
  
  Create a new KStream by transforming the value of each record in this stream into zero or more values with the same key in the new stream. Errors in the mapper are captured
  Type Parameters:
  
  VR - the value type of the result stream
  
  Parameters:
  
  mapper - a ValueMapperWithKey that computes the new output values
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  named - a Named config used to name the processor in the topology
  
  Returns:
  
  a KErrorStreamX that contains more or less records with unmodified keys and new values as well as captured errors
  
  See Also:
  
  flatMapValues(ValueMapperWithKey, Named)
  
  ErrorCapturingFlatValueMapperWithKey.captureErrors(ValueMapperWithKey, java.util.function.Predicate)
- peek
  
  KStreamX<K,V> peek(org.apache.kafka.streams.kstream.ForeachAction<? super K,? super V> action)
  
  Specified by:
  
  peek in interface org.apache.kafka.streams.kstream.KStream<K,V>
- peek
  
  KStreamX<K,V> peek(org.apache.kafka.streams.kstream.ForeachAction<? super K,? super V> action, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  peek in interface org.apache.kafka.streams.kstream.KStream<K,V>
- split
  
  BranchedKStreamX<K,V> split()
  
  Specified by:
  
  split in interface org.apache.kafka.streams.kstream.KStream<K,V>
- split
  
  BranchedKStreamX<K,V> split(org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  split in interface org.apache.kafka.streams.kstream.KStream<K,V>
- merge
  
  KStreamX<K,V> merge(org.apache.kafka.streams.kstream.KStream<K,V> stream)
  
  Specified by:
  
  merge in interface org.apache.kafka.streams.kstream.KStream<K,V>
- merge
  
  KStreamX<K,V> merge(org.apache.kafka.streams.kstream.KStream<K,V> stream, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  merge in interface org.apache.kafka.streams.kstream.KStream<K,V>
- repartition
  
  KStreamX<K,V> repartition()
  
  Specified by:
  
  repartition in interface org.apache.kafka.streams.kstream.KStream<K,V>
- repartition
  
  KStreamX<K,V> repartition(org.apache.kafka.streams.kstream.Repartitioned<K,V> repartitioned)
  
  Specified by:
  
  repartition in interface org.apache.kafka.streams.kstream.KStream<K,V>
- repartition
  
  KStreamX<K,V> repartition(RepartitionedX<K,V> repartitioned)
  See Also:
  
  repartition(Repartitioned)
- to
  
  void to(String topic, ProducedX<K,V> produced)
  See Also:
  
  KStream.to(String, Produced)
- to
  
  void to(org.apache.kafka.streams.processor.TopicNameExtractor<K,V> topicExtractor, ProducedX<K,V> produced)
  See Also:
  
  KStream.to(TopicNameExtractor, Produced)
- toOutputTopic
  
  void toOutputTopic()
  
  Materialize KStream to StreamsTopicConfig.getOutputTopic()
  See Also:
  
  KStream.to(String)
- toOutputTopic
  
  void toOutputTopic(org.apache.kafka.streams.kstream.Produced<K,V> produced)
  
  Materialize KStream to StreamsTopicConfig.getOutputTopic()
  Parameters:
  
  produced - define optional parameters for materializing the stream
  
  See Also:
  
  KStream.to(String, Produced)
- toOutputTopic
  
  void toOutputTopic(ProducedX<K,V> produced)
  
  Materialize KStream to StreamsTopicConfig.getOutputTopic()
  Parameters:
  
  produced - define optional parameters for materializing the stream
  
  See Also:
  
  KStream.to(String, Produced)
- toOutputTopic
  
  void toOutputTopic(String label)
  
  Materialize KStream to StreamsTopicConfig.getOutputTopic(String)
  Parameters:
  
  label - label of output topic
  
  See Also:
  
  KStream.to(String)
- toOutputTopic
  
  void toOutputTopic(String label, org.apache.kafka.streams.kstream.Produced<K,V> produced)
  
  Materialize KStream to StreamsTopicConfig.getOutputTopic(String)
  Parameters:
  
  label - label of output topic
  
  produced - define optional parameters for materializing the stream
  
  See Also:
  
  KStream.to(String, Produced)
- toOutputTopic
  
  void toOutputTopic(String label, ProducedX<K,V> produced)
  
  Materialize KStream to StreamsTopicConfig.getOutputTopic(String)
  Parameters:
  
  label - label of output topic
  
  produced - define optional parameters for materializing the stream
  
  See Also:
  
  KStream.to(String, Produced)
- toErrorTopic
  
  void toErrorTopic()
  
  Materialize KStream to StreamsTopicConfig.getErrorTopic()
  See Also:
  
  KStream.to(String)
- toErrorTopic
  
  void toErrorTopic(org.apache.kafka.streams.kstream.Produced<K,V> produced)
  
  Materialize KStream to StreamsTopicConfig.getErrorTopic()
  Parameters:
  
  produced - define optional parameters for materializing the stream
  
  See Also:
  
  KStream.to(String, Produced)
- toErrorTopic
  
  void toErrorTopic(ProducedX<K,V> produced)
  
  Materialize KStream to StreamsTopicConfig.getErrorTopic()
  Parameters:
  
  produced - define optional parameters for materializing the stream
  
  See Also:
  
  KStream.to(String, Produced)
- toTable
  
  KTableX<K,V> toTable()
  
  Specified by:
  
  toTable in interface org.apache.kafka.streams.kstream.KStream<K,V>
- toTable
  
  KTableX<K,V> toTable(org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  toTable in interface org.apache.kafka.streams.kstream.KStream<K,V>
- toTable
  
  KTableX<K,V> toTable(org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
  
  Specified by:
  
  toTable in interface org.apache.kafka.streams.kstream.KStream<K,V>
- toTable
  
  KTableX<K,V> toTable(MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
  See Also:
  
  toTable(Materialized)
- toTable
  
  KTableX<K,V> toTable(org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
  
  Specified by:
  
  toTable in interface org.apache.kafka.streams.kstream.KStream<K,V>
- toTable
  
  KTableX<K,V> toTable(org.apache.kafka.streams.kstream.Named named, MaterializedX<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
  See Also:
  
  toTable(Named, Materialized)
- groupBy
  
  <KR> KGroupedStreamX<KR,V> groupBy(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,KR> keySelector)
  
  Specified by:
  
  groupBy in interface org.apache.kafka.streams.kstream.KStream<K,V>
- groupBy
  
  <KR> KGroupedStreamX<KR,V> groupBy(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,KR> keySelector, org.apache.kafka.streams.kstream.Grouped<KR,V> grouped)
  
  Specified by:
  
  groupBy in interface org.apache.kafka.streams.kstream.KStream<K,V>
- groupBy
  
  <KR> KGroupedStreamX<KR,V> groupBy(org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,KR> keySelector, GroupedX<KR,V> grouped)
  See Also:
  
  groupBy(KeyValueMapper, Grouped)
- groupByKey
  
  KGroupedStreamX<K,V> groupByKey()
  
  Specified by:
  
  groupByKey in interface org.apache.kafka.streams.kstream.KStream<K,V>
- groupByKey
  
  KGroupedStreamX<K,V> groupByKey(org.apache.kafka.streams.kstream.Grouped<K,V> grouped)
  
  Specified by:
  
  groupByKey in interface org.apache.kafka.streams.kstream.KStream<K,V>
- groupByKey
  
  KGroupedStreamX<K,V> groupByKey(GroupedX<K,V> grouped)
  See Also:
  
  groupByKey(Grouped)
- join
  
  <VO, VR> KStreamX<K,VR> join(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows)
  
  Specified by:
  
  join in interface org.apache.kafka.streams.kstream.KStream<K,V>
- join
  
  <VO, VR> KStreamX<K,VR> join(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows)
  
  Specified by:
  
  join in interface org.apache.kafka.streams.kstream.KStream<K,V>
- join
  
  <VO, VR> KStreamX<K,VR> join(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, org.apache.kafka.streams.kstream.StreamJoined<K,V,VO> streamJoined)
  
  Specified by:
  
  join in interface org.apache.kafka.streams.kstream.KStream<K,V>
- join
  
  <VO, VR> KStreamX<K,VR> join(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, StreamJoinedX<K,V,VO> streamJoined)
  See Also:
  
  join(KStream, ValueJoiner, JoinWindows, StreamJoined)
- join
  
  <VO, VR> KStreamX<K,VR> join(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, org.apache.kafka.streams.kstream.StreamJoined<K,V,VO> streamJoined)
  
  Specified by:
  
  join in interface org.apache.kafka.streams.kstream.KStream<K,V>
- join
  
  <VO, VR> KStreamX<K,VR> join(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, StreamJoinedX<K,V,VO> streamJoined)
  See Also:
  
  join(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined)
- leftJoin
  
  <VO, VR> KStreamX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows)
  
  Specified by:
  
  leftJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- leftJoin
  
  <VO, VR> KStreamX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows)
  
  Specified by:
  
  leftJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- leftJoin
  
  <VO, VR> KStreamX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, org.apache.kafka.streams.kstream.StreamJoined<K,V,VO> streamJoined)
  
  Specified by:
  
  leftJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- leftJoin
  
  <VO, VR> KStreamX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, StreamJoinedX<K,V,VO> streamJoined)
  See Also:
  
  leftJoin(KStream, ValueJoiner, JoinWindows, StreamJoined)
- leftJoin
  
  <VO, VR> KStreamX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, org.apache.kafka.streams.kstream.StreamJoined<K,V,VO> streamJoined)
  
  Specified by:
  
  leftJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- leftJoin
  
  <VO, VR> KStreamX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, StreamJoinedX<K,V,VO> streamJoined)
  See Also:
  
  leftJoin(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined)
- outerJoin
  
  <VO, VR> KStreamX<K,VR> outerJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows)
  
  Specified by:
  
  outerJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- outerJoin
  
  <VO, VR> KStreamX<K,VR> outerJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows)
  
  Specified by:
  
  outerJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- outerJoin
  
  <VO, VR> KStreamX<K,VR> outerJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, org.apache.kafka.streams.kstream.StreamJoined<K,V,VO> streamJoined)
  
  Specified by:
  
  outerJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- outerJoin
  
  <VO, VR> KStreamX<K,VR> outerJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, StreamJoinedX<K,V,VO> streamJoined)
  See Also:
  
  outerJoin(KStream, ValueJoiner, JoinWindows, StreamJoined)
- outerJoin
  
  <VO, VR> KStreamX<K,VR> outerJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, org.apache.kafka.streams.kstream.StreamJoined<K,V,VO> streamJoined)
  
  Specified by:
  
  outerJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- outerJoin
  
  <VO, VR> KStreamX<K,VR> outerJoin(org.apache.kafka.streams.kstream.KStream<K,VO> otherStream, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VO,? extends VR> joiner, org.apache.kafka.streams.kstream.JoinWindows windows, StreamJoinedX<K,V,VO> streamJoined)
  See Also:
  
  outerJoin(KStream, ValueJoinerWithKey, JoinWindows, StreamJoined)
- join
  
  <VT, VR> KStreamX<K,VR> join(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VT,? extends VR> joiner)
  
  Specified by:
  
  join in interface org.apache.kafka.streams.kstream.KStream<K,V>
- join
  
  <VT, VR> KStreamX<K,VR> join(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VT,? extends VR> joiner)
  
  Specified by:
  
  join in interface org.apache.kafka.streams.kstream.KStream<K,V>
- join
  
  <VT, VR> KStreamX<K,VR> join(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VT,? extends VR> joiner, org.apache.kafka.streams.kstream.Joined<K,V,VT> joined)
  
  Specified by:
  
  join in interface org.apache.kafka.streams.kstream.KStream<K,V>
- join
  
  <VT, VR> KStreamX<K,VR> join(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VT,? extends VR> joiner, JoinedX<K,V,VT> joined)
  See Also:
  
  join(KTable, ValueJoiner, Joined)
- join
  
  <VT, VR> KStreamX<K,VR> join(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VT,? extends VR> joiner, org.apache.kafka.streams.kstream.Joined<K,V,VT> joined)
  
  Specified by:
  
  join in interface org.apache.kafka.streams.kstream.KStream<K,V>
- join
  
  <VT, VR> KStreamX<K,VR> join(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VT,? extends VR> joiner, JoinedX<K,V,VT> joined)
  See Also:
  
  join(KTable, ValueJoinerWithKey, Joined)
- leftJoin
  
  <VT, VR> KStreamX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VT,? extends VR> joiner)
  
  Specified by:
  
  leftJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- leftJoin
  
  <VT, VR> KStreamX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VT,? extends VR> joiner)
  
  Specified by:
  
  leftJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- leftJoin
  
  <VT, VR> KStreamX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VT,? extends VR> joiner, org.apache.kafka.streams.kstream.Joined<K,V,VT> joined)
  
  Specified by:
  
  leftJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- leftJoin
  
  <VT, VR> KStreamX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super VT,? extends VR> joiner, JoinedX<K,V,VT> joined)
  See Also:
  
  leftJoin(KTable, ValueJoiner, Joined)
- leftJoin
  
  <VT, VR> KStreamX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VT,? extends VR> joiner, org.apache.kafka.streams.kstream.Joined<K,V,VT> joined)
  
  Specified by:
  
  leftJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- leftJoin
  
  <VT, VR> KStreamX<K,VR> leftJoin(org.apache.kafka.streams.kstream.KTable<K,VT> table, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super VT,? extends VR> joiner, JoinedX<K,V,VT> joined)
  See Also:
  
  leftJoin(KTable, ValueJoinerWithKey, Joined)
- join
  
  <GK, GV, RV> KStreamX<K,RV> join(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super GV,? extends RV> joiner)
  
  Specified by:
  
  join in interface org.apache.kafka.streams.kstream.KStream<K,V>
- join
  
  <GK, GV, RV> KStreamX<K,RV> join(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super GV,? extends RV> joiner)
  
  Specified by:
  
  join in interface org.apache.kafka.streams.kstream.KStream<K,V>
- join
  
  <GK, GV, RV> KStreamX<K,RV> join(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super GV,? extends RV> joiner, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  join in interface org.apache.kafka.streams.kstream.KStream<K,V>
- join
  
  <GK, GV, RV> KStreamX<K,RV> join(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super GV,? extends RV> joiner, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  join in interface org.apache.kafka.streams.kstream.KStream<K,V>
- leftJoin
  
  <GK, GV, RV> KStreamX<K,RV> leftJoin(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super GV,? extends RV> valueJoiner)
  
  Specified by:
  
  leftJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- leftJoin
  
  <GK, GV, RV> KStreamX<K,RV> leftJoin(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super GV,? extends RV> valueJoiner)
  
  Specified by:
  
  leftJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- leftJoin
  
  <GK, GV, RV> KStreamX<K,RV> leftJoin(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoiner<? super V,? super GV,? extends RV> valueJoiner, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  leftJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- leftJoin
  
  <GK, GV, RV> KStreamX<K,RV> leftJoin(org.apache.kafka.streams.kstream.GlobalKTable<GK,GV> globalTable, org.apache.kafka.streams.kstream.KeyValueMapper<? super K,? super V,? extends GK> keySelector, org.apache.kafka.streams.kstream.ValueJoinerWithKey<? super K,? super V,? super GV,? extends RV> valueJoiner, org.apache.kafka.streams.kstream.Named named)
  
  Specified by:
  
  leftJoin in interface org.apache.kafka.streams.kstream.KStream<K,V>
- process
  
  <KOut, VOut> KStreamX<KOut,VOut> process(org.apache.kafka.streams.processor.api.ProcessorSupplier<? super K,? super V,KOut,VOut> processorSupplier, String... stateStoreNames)
  
  Specified by:
  
  process in interface org.apache.kafka.streams.kstream.KStream<K,V>
- processCapturingErrors
  
  <KOut, VOut> KErrorStreamX<K,V,KOut,VOut> processCapturingErrors(org.apache.kafka.streams.processor.api.ProcessorSupplier<? super K,? super V,KOut,VOut> processorSupplier, String... stateStoreNames)
  
  Process all records in this stream, one record at a time, by applying a Processor. Errors in the mapper are captured
  Type Parameters:
  
  KOut - the key type of the result stream
  
  VOut - the value type of the result stream
  
  Parameters:
  
  processorSupplier - an instance of ProcessorSupplier that generates a newly constructed Processor
  
  stateStoreNames - the names of the state store used by the processor
  
  Returns:
  
  a KErrorStreamX that contains records with new key and value as well as captured errors
  
  See Also:
  
  process(ProcessorSupplier, String...)
  
  ErrorCapturingProcessor.captureErrors(ProcessorSupplier)
- processCapturingErrors
  
  <KOut, VOut> KErrorStreamX<K,V,KOut,VOut> processCapturingErrors(org.apache.kafka.streams.processor.api.ProcessorSupplier<? super K,? super V,KOut,VOut> processorSupplier, Predicate<Exception> errorFilter, String... stateStoreNames)
  
  Process all records in this stream, one record at a time, by applying a Processor. Errors in the mapper are captured
  Type Parameters:
  
  KOut - the key type of the result stream
  
  VOut - the value type of the result stream
  
  Parameters:
  
  processorSupplier - an instance of ProcessorSupplier that generates a newly constructed Processor
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  stateStoreNames - the names of the state store used by the processor
  
  Returns:
  
  a KErrorStreamX that contains records with new key and value as well as captured errors
  
  See Also:
  
  process(ProcessorSupplier, String...)
  
  ErrorCapturingProcessor.captureErrors(ProcessorSupplier, java.util.function.Predicate)
- process
  
  <KOut, VOut> KStreamX<KOut,VOut> process(org.apache.kafka.streams.processor.api.ProcessorSupplier<? super K,? super V,KOut,VOut> processorSupplier, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)
  
  Specified by:
  
  process in interface org.apache.kafka.streams.kstream.KStream<K,V>
- processCapturingErrors
  
  <KOut, VOut> KErrorStreamX<K,V,KOut,VOut> processCapturingErrors(org.apache.kafka.streams.processor.api.ProcessorSupplier<? super K,? super V,KOut,VOut> processorSupplier, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)
  
  Process all records in this stream, one record at a time, by applying a Processor. Errors in the mapper are captured
  Type Parameters:
  
  KOut - the key type of the result stream
  
  VOut - the value type of the result stream
  
  Parameters:
  
  processorSupplier - an instance of ProcessorSupplier that generates a newly constructed Processor
  
  named - a Named config used to name the processor in the topology
  
  stateStoreNames - the names of the state store used by the processor
  
  Returns:
  
  a KErrorStreamX that contains records with new key and value as well as captured errors
  
  See Also:
  
  process(ProcessorSupplier, Named, String...)
  
  ErrorCapturingProcessor.captureErrors(ProcessorSupplier)
- processCapturingErrors
  
  <KOut, VOut> KErrorStreamX<K,V,KOut,VOut> processCapturingErrors(org.apache.kafka.streams.processor.api.ProcessorSupplier<? super K,? super V,KOut,VOut> processorSupplier, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)
  
  Process all records in this stream, one record at a time, by applying a Processor. Errors in the mapper are captured
  Type Parameters:
  
  KOut - the key type of the result stream
  
  VOut - the value type of the result stream
  
  Parameters:
  
  processorSupplier - an instance of ProcessorSupplier that generates a newly constructed Processor
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  named - a Named config used to name the processor in the topology
  
  stateStoreNames - the names of the state store used by the processor
  
  Returns:
  
  a KErrorStreamX that contains records with new key and value as well as captured errors
  
  See Also:
  
  process(ProcessorSupplier, Named, String...)
  
  ErrorCapturingProcessor.captureErrors(ProcessorSupplier, java.util.function.Predicate)
- processValues
  
  <VOut> KStreamX<K,VOut> processValues(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<? super K,? super V,VOut> processorSupplier, String... stateStoreNames)
  
  Specified by:
  
  processValues in interface org.apache.kafka.streams.kstream.KStream<K,V>
- processValuesCapturingErrors
  
  <VOut> KErrorStreamX<K,V,K,VOut> processValuesCapturingErrors(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<? super K,? super V,VOut> processorSupplier, String... stateStoreNames)
  
  Process all records in this stream, one record at a time, by applying a FixedKeyProcessor. Errors in the mapper are captured
  Type Parameters:
  
  VOut - the value type of the result stream
  
  Parameters:
  
  processorSupplier - an instance of FixedKeyProcessorSupplier that generates a newly constructed FixedKeyProcessor
  
  stateStoreNames - the names of the state store used by the processor
  
  Returns:
  
  a KErrorStreamX that contains records with unmodified key and new values as well as captured errors
  
  See Also:
  
  processValues(FixedKeyProcessorSupplier, String...)
  
  ErrorCapturingValueProcessor.captureErrors(FixedKeyProcessorSupplier)
- processValuesCapturingErrors
  
  <VOut> KErrorStreamX<K,V,K,VOut> processValuesCapturingErrors(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<? super K,? super V,VOut> processorSupplier, Predicate<Exception> errorFilter, String... stateStoreNames)
  
  Process all records in this stream, one record at a time, by applying a FixedKeyProcessor. Errors in the mapper are captured
  Type Parameters:
  
  VOut - the value type of the result stream
  
  Parameters:
  
  processorSupplier - an instance of FixedKeyProcessorSupplier that generates a newly constructed FixedKeyProcessor
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  stateStoreNames - the names of the state store used by the processor
  
  Returns:
  
  a KErrorStreamX that contains records with unmodified key and new values as well as captured errors
  
  See Also:
  
  processValues(FixedKeyProcessorSupplier, String...)
  
  ErrorCapturingValueProcessor.captureErrors(FixedKeyProcessorSupplier, java.util.function.Predicate)
- processValues
  
  <VOut> KStreamX<K,VOut> processValues(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<? super K,? super V,VOut> processorSupplier, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)
  
  Specified by:
  
  processValues in interface org.apache.kafka.streams.kstream.KStream<K,V>
- processValuesCapturingErrors
  
  <VOut> KErrorStreamX<K,V,K,VOut> processValuesCapturingErrors(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<? super K,? super V,VOut> processorSupplier, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)
  
  Process all records in this stream, one record at a time, by applying a FixedKeyProcessor. Errors in the mapper are captured
  Type Parameters:
  
  VOut - the value type of the result stream
  
  Parameters:
  
  processorSupplier - an instance of FixedKeyProcessorSupplier that generates a newly constructed FixedKeyProcessor
  
  named - a Named config used to name the processor in the topology
  
  stateStoreNames - the names of the state store used by the processor
  
  Returns:
  
  a KErrorStreamX that contains records with unmodified key and new values as well as captured errors
  
  See Also:
  
  processValues(FixedKeyProcessorSupplier, Named, String...)
  
  ErrorCapturingValueProcessor.captureErrors(FixedKeyProcessorSupplier)
- processValuesCapturingErrors
  
  <VOut> KErrorStreamX<K,V,K,VOut> processValuesCapturingErrors(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier<? super K,? super V,VOut> processorSupplier, Predicate<Exception> errorFilter, org.apache.kafka.streams.kstream.Named named, String... stateStoreNames)
  
  Process all records in this stream, one record at a time, by applying a FixedKeyProcessor. Errors in the mapper are captured
  Type Parameters:
  
  VOut - the value type of the result stream
  
  Parameters:
  
  processorSupplier - an instance of FixedKeyProcessorSupplier that generates a newly constructed FixedKeyProcessor
  
  errorFilter - expression that filters errors which should be thrown and not captured
  
  named - a Named config used to name the processor in the topology
  
  stateStoreNames - the names of the state store used by the processor
  
  Returns:
  
  a KErrorStreamX that contains records with unmodified key and new values as well as captured errors
  
  See Also:
  
  processValues(FixedKeyProcessorSupplier, Named, String...)
  
  ErrorCapturingValueProcessor.captureErrors(FixedKeyProcessorSupplier, java.util.function.Predicate)

Interface KStreamX<K,V>

Method Summary

Methods inherited from interface org.apache.kafka.streams.kstream.KStream

Method Details

filter

filter

filterNot

filterNot

selectKey

selectKey

map

mapCapturingErrors

mapCapturingErrors

map

mapCapturingErrors

mapCapturingErrors

mapValues

mapValuesCapturingErrors

mapValuesCapturingErrors

mapValues

mapValuesCapturingErrors

mapValuesCapturingErrors

mapValues

mapValuesCapturingErrors

mapValuesCapturingErrors

mapValues

mapValuesCapturingErrors

mapValuesCapturingErrors

flatMap

flatMapCapturingErrors

flatMapCapturingErrors

flatMap

flatMapCapturingErrors

flatMapCapturingErrors

flatMapValues

flatMapValuesCapturingErrors

flatMapValuesCapturingErrors

flatMapValues

flatMapValuesCapturingErrors

flatMapValuesCapturingErrors

flatMapValues

flatMapValuesCapturingErrors

flatMapValuesCapturingErrors

flatMapValues

flatMapValuesCapturingErrors

flatMapValuesCapturingErrors

peek

peek

split

split

merge

merge

repartition

repartition

repartition

to

to

toOutputTopic

toOutputTopic

toOutputTopic

toOutputTopic

toOutputTopic

toOutputTopic

toErrorTopic

toErrorTopic

toErrorTopic

toTable

toTable

toTable

toTable

toTable

toTable

groupBy

groupBy

groupBy

groupByKey

groupByKey

groupByKey

join

join