我正在尝试将数据从一种格式转换为另一种格式（从一种模式转换为另一种模式）。
例子：

payload = {
    'a' : 'a1',
    'b' : 'b1'
}

我想把这个有效载荷转换成另一种形式

payload_transform = {
   'a':{
      'b' : 'b1'
    }
    'c' : 'a1'
}

考虑一下这些数据( payload )是从Kafka来的，我想看看 payload_transform 在消费者中，随着转变
使用ksql有可能吗？
更新时间：
我们可以做一个层次：

payload = {
    'a' : 'a1',
    'b' : 'b1'
}

到

payload = {
    'confluent' : 'a1',
    'b' : 'b1'
}

我们可以添加条件吗？
例如：如果有效负载中存在“b”键，则生成

payload = {
        'confluent' : 'a1',
        'b' : 'b1'
    }

否则：

payload = {
        'kafka' : 'a1',
        'b' : 'b1'
    }