|Project Name||Stars||Downloads||Repos Using This||Packages Using This||Most Recent Commit||Total Releases||Latest Release||Open Issues||License||Language|
|Kafka||25,098||21 hours ago||1,034||apache-2.0||Java|
|Mirror of Apache Kafka|
|Sarama||10,023||1,759||7 days ago||152||August 11, 2022||327||mit||Go|
|Sarama is a Go library for Apache Kafka.|
|Debezium||8,548||54||32||20 hours ago||137||September 16, 2022||49||apache-2.0||Java|
|Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.|
|Librdkafka||6,717||a day ago||274||other||C|
|The Apache Kafka C/C++ library|
|Kafka Ui||5,991||a day ago||287||apache-2.0||Java|
|Open-Source Web UI for Apache Kafka Management|
|Strimzi Kafka Operator||3,868||2||21 hours ago||34||September 06, 2022||143||apache-2.0||Java|
|Apache Kafka® running on Kubernetes|
|Goka||2,116||3||17||2 months ago||62||July 12, 2022||16||bsd-3-clause||Go|
|Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.|
|Spring Kafka||1,904||1,691||225||4 days ago||160||September 19, 2022||47||apache-2.0||Java|
|Provides Familiar Spring Abstractions for Apache Kafka|
|Kaf||1,858||2||5 days ago||71||July 18, 2022||54||apache-2.0||Go|
|Modern CLI for Apache Kafka, written in Go.|
|Oryx||1,796||16||2||2 years ago||14||November 25, 2018||1||apache-2.0||Java|
|Oryx 2: Lambda architecture on Apache Spark, Apache Kafka for real-time large scale machine learning|
Decaton is a streaming task processing framework built on top of Apache Kafka. It is designed to enable "concurrent processing of records consumed from one partition" which isn't possible in many Kafka consumer frameworks.
Here is the list of property that Decaton enables by default:
Decaton is a library rather than a full-stack execution environment so you can easily integrate it into your existing/new JVM applications just by adding few lines of artifact dependencies.
Since it has been designed, optimized and being used for LINE's server system which produces over 1 million, I/O intensive tasks per second for each stream, its internal implementation for enabling concurrent processing of records is highly optimized and can produce ideal throughput with minimal count of servers, maximizing their resource utilization.
Please see Getting Started
It's good idea to use Decaton when you have requirement for high-throughput and/or low-latency processing capability with your processing logic containing I/O access against external systems (e.g, DB access, Web API access) which tends to apply certain processing latency in each tasks.
It would be better idea to look for other frameworks like Kafka Streams when you need to do complex stream processing/aggregation such as streams join, windowed processing without needing to access external storage/web APIs.
Below is the minimum dependencies to add Decaton artifacts into your Gradle project. It's for people who prefers to try the APIs first by adding it into your project, please see Getting Started for the detailed explanation and proper use of it.
// For task producers implementation "com.linecorp.decaton:decaton-common:$DECATON_VERSION" implementation "com.linecorp.decaton:decaton-client:$DECATON_VERSION" // For processors implementation "com.linecorp.decaton:decaton-common:$DECATON_VERSION" implementation "com.linecorp.decaton:decaton-processor:$DECATON_VERSION"
The core feature of Decaton is support for concurrent processing of records consumed from one partition. See Why Decaton part of document for the detail.
Besides that, it got a lot of unique and useful features through its adoption spread for many services at LINE which are all came out of real needs for building services. Below are some examples. See Index for the full list.
High performance is one of the biggest functionalities of Decaton so we're carefully tracking its performance transitions commit-by-commit. You can see performance tracking dashboard from here (Note that the actual performance could be more or less depending on machine resource and configuration).
We use Gradle to build this project.
If you believe you have discovered a vulnerability or have an issue related to security, please contact the maintainer directly or send us a email to [email protected] before sending a pull request.
Copyright 2020 LINE Corporation Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
See LICENSE for more detail.
Below people made great contributions to this project in early days but their name doesn't appear in commit history because we had to erase commit logs when open-sourcing it by security reasons. Thank you so much for your contributions!
Haruki Okada, Wonpill Seo, Szuyung Wang, Vincent Pericart, Ryosuke Hasebe, Maytee Chinavanichkit, Junpei Koyama, Yusuke Imai, Alex Moreno