イントロ
  • 前提条件(Kafka Streams)
  • Kafka Streams Exampleファイルの解説
Stateless API
  • filter(), filterNot()
  • map(), mapValues(), flatMap(), flatMapValues()
  • peek(), print(), foreach()
  • split(), branch(), merge()
Stateful API
  • Stateless vs Stateful(StateStore)
  • Co-Partitioning
  • leftJoin()
  • window(), aggregation()
  • toStream(), toTable()
  • groupBy(), groupByKey(),repartition(), selectKey()
  • process(), processValues()
Kafka Streams - Interactive Queries
  • Interactive Queriesとは
  • Example
その他
  • Kafka Streamsメトリックの出力
  • エラーの対応方法
  • TaskとThreadの管理
  • Streams Configの設定