Data Integration as Service: Kafka-Streamsの紹介 アドベントカレンダー4日目のKafka-Connectに続き,今回はApache Kafka 0.10から同梱されていKafka-Streamsを紹介します。Kafka-StreamsはKafkaから入力トピックからデータを受け取り、何らかの処理を行って、Kafkaの出力トピックにデータを書き戻すという、ストリーミングアプリを書くためのライブラリです。Kafka-Connectと違い、ライブラリですので単体では何もできません。 ※能書きはいいから、手っ取り早くどう使うのか知りたいという人は"まとめ"->"DSL"の順に読んでください。 特徴 ミリ秒単位のレイテンシーでイベント毎の処理(マイクロバッチではない) DSLと低レベルAPIの2つを提供 ステートフル・ステートレスの処理 ストリームJOIN・
![Data Integration as Service: Kafka-Streamsの紹介 - Qiita](https://cdn-ak-scissors.b.st-hatena.com/image/square/013b023d730798d5e37f2480a6a86e4bd2af7c77/height=288;version=1;width=512/https%3A%2F%2Fqiita-user-contents.imgix.net%2Fhttps%253A%252F%252Fcdn.qiita.com%252Fassets%252Fpublic%252Fadvent-calendar-ogp-background-7940cd1c8db80a7ec40711d90f43539e.jpg%3Fixlib%3Drb-4.0.0%26w%3D1200%26mark64%3DaHR0cHM6Ly9xaWl0YS11c2VyLWNvbnRlbnRzLmltZ2l4Lm5ldC9-dGV4dD9peGxpYj1yYi00LjAuMCZ3PTk3MiZoPTM3OCZ0eHQ9RGF0YSUyMEludGVncmF0aW9uJTIwYXMlMjBTZXJ2aWNlJTNBJTIwS2Fma2EtU3RyZWFtcyVFMyU4MSVBRSVFNyVCNCVCOSVFNCVCQiU4QiZ0eHQtYWxpZ249bGVmdCUyQ3RvcCZ0eHQtY29sb3I9JTIzM0EzQzNDJnR4dC1mb250PUhpcmFnaW5vJTIwU2FucyUyMFc2JnR4dC1zaXplPTU2JnM9NDk4NGJiYThmOTE1ZjY1MjcxZWRhYmFhNTg2Nzc2NmY%26mark-x%3D120%26mark-y%3D96%26blend64%3DaHR0cHM6Ly9xaWl0YS11c2VyLWNvbnRlbnRzLmltZ2l4Lm5ldC9-dGV4dD9peGxpYj1yYi00LjAuMCZoPTc2Jnc9OTcyJnR4dD0lNDBrbm9ndWNoaSZ0eHQtY29sb3I9JTIzM0EzQzNDJnR4dC1mb250PUhpcmFnaW5vJTIwU2FucyUyMFc2JnR4dC1zaXplPTM2JnR4dC1hbGlnbj1sZWZ0JTJDdG9wJnM9N2Y3MWUxOTk1ODg2NjlhNGMxMTcxYTEyNmRiMTJmMzA%26blend-x%3D120%26blend-y%3D500%26blend-mode%3Dnormal%26s%3D09fafd10db3b083387f8deffbb9583eb)