Namespace MASES.KNet.Streams
Classes
- KNetClientSupplier
KNet implementation of KafkaClientSupplier
- KNetStreams
KNet extension of KafkaStreams
- KeyValueSupport<K, V>
Support class for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/KeyValue.html#org.apache.kafka.streams.KeyValue
- KeyValue<K, V, TJVMK, TJVMV>
KNet implementation of KeyValue<K, V>
- StreamsBuilder
KNet extension of StreamsBuilder
- StreamsConfigBuilder
Builder for StreamsConfig
- TimestampedKeyValue<K, V, TJVMK, TJVMV>
KNet implementation of ValueAndTimestamp<V>
- TimestampedWindowedKeyValue<K, V, TJVMK, TJVMV>
KNet implementation of KeyValue<K, V>
- TopologyConfig
KNet implementation of TopologyConfig
- WindowedKeyValue<K, V, TJVMK, TJVMV>
KNet implementation of KeyValue<K, V> where the key is Windowed<K>