Kafka Streams
E702192
Kafka Streams is a Java library for building real-time, distributed stream processing applications on top of Apache Kafka.
Statements (50)
| Predicate | Object |
|---|---|
| instanceOf |
Apache Kafka ecosystem component
ⓘ
Java library ⓘ stream processing library ⓘ |
| builtOnTopOf | Apache Kafka NERFINISHED ⓘ |
| deploymentModel |
embedded in client applications
ⓘ
no separate processing cluster required ⓘ |
| designedFor |
building real-time applications
ⓘ
distributed stream processing ⓘ event-driven microservices ⓘ stateful stream processing ⓘ |
| developedBy | Apache Software Foundation NERFINISHED ⓘ |
| documentationURL | https://kafka.apache.org/documentation/streams ⓘ |
| domain |
event streaming
ⓘ
real-time data processing ⓘ stream processing ⓘ |
| introducedIn | Apache Kafka 0.10 NERFINISHED ⓘ |
| license | Apache License 2.0 ⓘ |
| officialWebsite | https://kafka.apache.org/streams ⓘ |
| partOf | Apache Kafka NERFINISHED ⓘ |
| persistsStateTo | Kafka changelog topics NERFINISHED ⓘ |
| programmingLanguage | Java ⓘ |
| provides |
GlobalKTable abstraction
ⓘ
KStream abstraction ⓘ KTable abstraction ⓘ high-level DSL ⓘ low-level Processor API ⓘ |
| runsOn | Java Virtual Machine NERFINISHED ⓘ |
| scalesBy | Kafka topic partitioning ⓘ |
| storesStateIn | RocksDB NERFINISHED ⓘ |
| supports |
at-least-once processing semantics
ⓘ
event-time processing ⓘ exactly-once processing semantics ⓘ exactly-once-v2 semantics in newer Kafka versions ⓘ fault tolerance ⓘ interactive queries ⓘ joins between streams ⓘ joins between streams and tables ⓘ local state stores ⓘ processing-time processing ⓘ repartitioning of streams ⓘ stateful transformations ⓘ stateless transformations ⓘ topology-based processing model ⓘ windowed aggregations ⓘ |
| supportsProgrammingLanguage |
Java
NERFINISHED
ⓘ
Kotlin NERFINISHED ⓘ Scala NERFINISHED ⓘ |
| uses |
Kafka consumer API
NERFINISHED
ⓘ
Kafka producer API NERFINISHED ⓘ Kafka topics ⓘ |
Referenced by (2)
Full triples — surface form annotated when it differs from this entity's canonical label.