Namespace MASES.KNet.Streams
Classes
- KNetClientSupplier
KNet implementation of KafkaClientSupplier
- KNetStreams
KNet extension of KafkaStreams
- 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>