kafka-streamsのinternal topic

kafka-streamsにおけるトピックにはアプリケーションの外存在しているユーザートピックとアプリケーション管理するinternal topicがある

トピックの名前の形式は <application.id>-<operatorName>-<suffix>となっている

suffixは指定が無い場合グローバルなインクリメントする数字が適当に振られる

が、可読性と変更に対する堅牢性の観点から明示的に名前をつけるべき

可読性

filter-0000000001だとビジネスロジック的な意味が全く別らない。

変更に対する堅牢性

kafka-streamsトポロジーに変更があるとsuffixが変わってしまうので、ローリングアップデートで非常に困る

Named.asとかをstreams dslに渡す

kafka-streamsが古いとサポートされていない

このconfluentのガイドに書いてある