1

私のトピックの 1 つは、キーとして文字列 json を持っています - {"city":"X","id":22}。私のksqlステートメントでは、後でフィルタリングして結合できるように、1つではなく2つの異なるフィールドに抽出したいと考えています。ドキュメントでは、JSONとしてフォーマットするのではなく、文字列全体のみをキーに貼り付けることができるようです(FORMAT_VALUEのように)以下を参照してください...これに対するエレガントなソリューションの提案はありますか?

VALUE_FORMAT (必須) トピック内のメッセージ値のシリアル化形式を指定します。サポートされている形式: JSON、DELIMITED、および AVRO

KEY Kafka トピックのメッセージ キーを KSQL ストリームの列に関連付けます。

4

1 に答える 1