Kafka Streams KStream Arayüzü - Unbound Stream of Events

Giriş

Şu satırı dahil ederiz

import org.apache.kafka.streams.kstream.KStream;

Açıklaması şöyle

Kafka Streams provides two main abstractions for processing data: KStream and KTable. 

- A KStream represents an unbounded stream of records that can be transformed with stateless operations such as mapping, filtering, joining, and aggregating. 

- A KTable represents a changelog stream of records that can be queried by key and updated with stateful operations such as counting, grouping, windowing, and joining.

constructor

Örnek  - KStreamBuilder - Kullanmayın

KStreamBuilder  artık deprecated. Şöyle yaparız

KStreamBuilder builder = new KStreamBuilder();
//KStream for topic
KStream<String, String> textLines = builder.stream("TextLinesTopic");

Örnek

StreamBuilder tarafından yaratılır.. Şöyle yaparız

StreamsBuilder builder = new StreamsBuilder();
KStream<String, String> textLines = builder.stream("streams-plaintext-input");

aggregate metodu

KStream.aggregate metodu yazısına taşıdım

count metodu

KStreams.count metodu yazısına taşıdım

filter metodu

KStream.filter metodu yazısına taşıdım

filterNot metodu

KStream.filterNot metodu yazısına taşıdım

flatmapValues metodu

KStream.flatmapValues metodu yazısına taşıdım

groupBy metodu

KStream.groupBy metodu yazısına taşıdım

groupByKey metodu

KStream.groupByKey metodu yazısına taşıdım

map metodu

KStream.map metodu yazısına taşıdım

mapValues metodu

KStream.mapValues metodu yazısına taşıdım

to metodu

KStream.to metodu yazısına taşıdım

windowedBy metodu

KStream.windowedBy metodu yazısına taşıdım