ksqlDBにおけるストリーム処理の概念と、ストリーム処理でTopicのKeyを扱う方法について。試して理解出来るデモスクリプト付き。
Apache Flinkの最新バージョンが公開されました。ようやくAkkaへの依存が解消されたFlinkですが、それ以外にもストリーム処理/バッチ処理、その他様々な改善を含んだリリースとなりました。
Apache Kafkaの最新バージョンが公開されました。Tiered Storageがアーリーアクセスとして登場した他、Zookeeperのアップデート、KRaft Metadata Transaction等様々な新機能が追加されました。
ksqlDBにおいてTopicのKeyの扱い方やそのパターンについてのハンズオンです。
Confluent Cloudを利用してクリックストリームのデータを加工/分析するワークショップです。クリックストリーム用のテストデータの作成とksqlDBによるStream/Tableの利用方法、Pull Queryの基本的な使用方法等を体験いただけます。
ネットワーク機器のログをSplunkのUniversal Forwarderを利用してConfluentに転送し、ストリーム処理後にSplunkのHECに転送するサンドボックス環境。Splunk Universal Forwarderから送られるログを、Confluent内で機器ログ (CISCO ASA) とUniversal Forwarder自身のログ (SPLUNKD) にストリーム処理で分類。ストリーム処理にはksqlDBを利用。