text: {
    "plan" : [ {
      "@type" : "ksqlPlanV1",
      "statementText" : "CREATE STREAM TEST (ROWKEY BIGINT KEY, ID BIGINT, NAME STRING, VALUE BIGINT) WITH (KAFKA_TOPIC='left_topic', KEY='ID', VALUE_FORMAT='AVRO');",
      "ddlCommand" : {
        "@type" : "createStreamV1",
        "sourceName" : "TEST",
        "schema" : "`ROWKEY` BIGINT KEY, `ID` BIGINT, `NAME` STRING, `VALUE` BIGINT",
        "keyField" : "ID",
        "timestampColumn" : null,
        "topicName" : "left_topic",
        "formats" : {
          "keyFormat" : {
            "format" : "KAFKA",
            "properties" : { }
          },
          "valueFormat" : {
            "format" : "AVRO",
            "properties" : { }
          },
          "options" : [ ]
        },
        "windowInfo" : null
      },
      "queryPlan" : null
    }, {
      "@type" : "ksqlPlanV1",
      "statementText" : "CREATE STREAM TEST_STREAM (ROWKEY BIGINT KEY, ID BIGINT, F1 STRING, F2 BIGINT) WITH (KAFKA_TOPIC='right_topic', KEY='ID', VALUE_FORMAT='AVRO');",
      "ddlCommand" : {
        "@type" : "createStreamV1",
        "sourceName" : "TEST_STREAM",
        "schema" : "`ROWKEY` BIGINT KEY, `ID` BIGINT, `F1` STRING, `F2` BIGINT",
        "keyField" : "ID",
        "timestampColumn" : null,
        "topicName" : "right_topic",
        "formats" : {
          "keyFormat" : {
            "format" : "KAFKA",
            "properties" : { }
          },
          "valueFormat" : {
            "format" : "AVRO",
            "properties" : { }
          },
          "options" : [ ]
        },
        "windowInfo" : null
      },
      "queryPlan" : null
    }, {
      "@type" : "ksqlPlanV1",
      "statementText" : "CREATE STREAM INNER_JOIN AS SELECT\n  T.*,\n  TT.NAME NAME\nFROM TEST TT\nINNER JOIN TEST_STREAM T WITHIN 11 SECONDS ON ((T.ID = TT.ID))\nEMIT CHANGES",
      "ddlCommand" : {
        "@type" : "createStreamV1",
        "sourceName" : "INNER_JOIN",
        "schema" : "`ROWKEY` BIGINT KEY, `T_ROWTIME` BIGINT, `T_ROWKEY` BIGINT, `T_ID` BIGINT, `T_F1` STRING, `T_F2` BIGINT, `NAME` STRING",
        "keyField" : null,
        "timestampColumn" : null,
        "topicName" : "INNER_JOIN",
        "formats" : {
          "keyFormat" : {
            "format" : "KAFKA",
            "properties" : { }
          },
          "valueFormat" : {
            "format" : "AVRO",
            "properties" : { }
          },
          "options" : [ ]
        },
        "windowInfo" : null
      },
      "queryPlan" : {
        "sources" : [ "TEST", "TEST_STREAM" ],
        "sink" : "INNER_JOIN",
        "physicalPlan" : {
          "@type" : "streamSinkV1",
          "properties" : {
            "queryContext" : "INNER_JOIN"
          },
          "source" : {
            "@type" : "streamSelectV1",
            "properties" : {
              "queryContext" : "Project"
            },
            "source" : {
              "@type" : "streamStreamJoinV1",
              "properties" : {
                "queryContext" : "Join"
              },
              "joinType" : "INNER",
              "leftInternalFormats" : {
                "keyFormat" : {
                  "format" : "KAFKA",
                  "properties" : { }
                },
                "valueFormat" : {
                  "format" : "AVRO",
                  "properties" : { }
                },
                "options" : [ ]
              },
              "rightInternalFormats" : {
                "keyFormat" : {
                  "format" : "KAFKA",
                  "properties" : { }
                },
                "valueFormat" : {
                  "format" : "AVRO",
                  "properties" : { }
                },
                "options" : [ ]
              },
              "leftSource" : {
                "@type" : "streamSelectV1",
                "properties" : {
                  "queryContext" : "PrependAliasLeft"
                },
                "source" : {
                  "@type" : "streamSourceV1",
                  "properties" : {
                    "queryContext" : "KafkaTopic_Left/Source"
                  },
                  "topicName" : "left_topic",
                  "formats" : {
                    "keyFormat" : {
                      "format" : "KAFKA",
                      "properties" : { }
                    },
                    "valueFormat" : {
                      "format" : "AVRO",
                      "properties" : { }
                    },
                    "options" : [ ]
                  },
                  "timestampColumn" : null,
                  "sourceSchema" : "`ROWKEY` BIGINT KEY, `ID` BIGINT, `NAME` STRING, `VALUE` BIGINT"
                },
                "selectExpressions" : [ "ID AS TT_ID", "NAME AS TT_NAME", "VALUE AS TT_VALUE", "ROWTIME AS TT_ROWTIME", "ROWKEY AS TT_ROWKEY" ]
              },
              "rightSource" : {
                "@type" : "streamSelectV1",
                "properties" : {
                  "queryContext" : "PrependAliasRight"
                },
                "source" : {
                  "@type" : "streamSourceV1",
                  "properties" : {
                    "queryContext" : "KafkaTopic_Right/Source"
                  },
                  "topicName" : "right_topic",
                  "formats" : {
                    "keyFormat" : {
                      "format" : "KAFKA",
                      "properties" : { }
                    },
                    "valueFormat" : {
                      "format" : "AVRO",
                      "properties" : { }
                    },
                    "options" : [ ]
                  },
                  "timestampColumn" : null,
                  "sourceSchema" : "`ROWKEY` BIGINT KEY, `ID` BIGINT, `F1` STRING, `F2` BIGINT"
                },
                "selectExpressions" : [ "ID AS T_ID", "F1 AS T_F1", "F2 AS T_F2", "ROWTIME AS T_ROWTIME", "ROWKEY AS T_ROWKEY" ]
              },
              "beforeMillis" : 11.000000000,
              "afterMillis" : 11.000000000
            },
            "selectExpressions" : [ "T_ROWTIME AS T_ROWTIME", "T_ROWKEY AS T_ROWKEY", "T_ID AS T_ID", "T_F1 AS T_F1", "T_F2 AS T_F2", "TT_NAME AS NAME" ]
          },
          "formats" : {
            "keyFormat" : {
              "format" : "KAFKA",
              "properties" : { }
            },
            "valueFormat" : {
              "format" : "AVRO",
              "properties" : { }
            },
            "options" : [ ]
          },
          "topicName" : "INNER_JOIN"
        },
        "queryId" : "CSAS_INNER_JOIN_0"
      }
    } ],
    "configs" : {
      "ksql.extension.dir" : "ext",
      "ksql.streams.cache.max.bytes.buffering" : "0",
      "ksql.security.extension.class" : null,
      "ksql.transient.prefix" : "transient_",
      "ksql.persistence.wrap.single.values" : "true",
      "ksql.authorization.cache.expiry.time.secs" : "30",
      "ksql.schema.registry.url" : "",
      "ksql.streams.default.deserialization.exception.handler" : "io.confluent.ksql.errors.LogMetricAndContinueExceptionHandler",
      "ksql.output.topic.name.prefix" : "",
      "ksql.streams.auto.offset.reset" : "earliest",
      "ksql.query.pull.enable.standby.reads" : "false",
      "ksql.connect.url" : "http://localhost:8083",
      "ksql.service.id" : "some.ksql.service.id",
      "ksql.internal.topic.min.insync.replicas" : "1",
      "ksql.streams.shutdown.timeout.ms" : "300000",
      "ksql.new.api.enabled" : "false",
      "ksql.streams.state.dir" : "/var/folders/p9/bk8xks6s2lndncftdbq36xh80000gp/T/confluent8393051053551629823",
      "ksql.internal.topic.replicas" : "1",
      "ksql.insert.into.values.enabled" : "true",
      "ksql.query.pull.max.allowed.offset.lag" : "9223372036854775807",
      "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
      "ksql.access.validator.enable" : "auto",
      "ksql.streams.bootstrap.servers" : "localhost:0",
      "ksql.streams.commit.interval.ms" : "2000",
      "ksql.metric.reporters" : "",
      "ksql.streams.auto.commit.interval.ms" : "0",
      "ksql.metrics.extension" : null,
      "ksql.streams.topology.optimization" : "all",
      "ksql.query.pull.streamsstore.rebalancing.timeout.ms" : "10000",
      "ksql.hidden.topics" : "_confluent.*,__confluent.*,_schemas,__consumer_offsets,__transaction_state,connect-configs,connect-offsets,connect-status,connect-statuses",
      "ksql.streams.num.stream.threads" : "4",
      "ksql.authorization.cache.max.entries" : "10000",
      "ksql.metrics.tags.custom" : "",
      "ksql.pull.queries.enable" : "true",
      "ksql.udfs.enabled" : "true",
      "ksql.udf.enable.security.manager" : "true",
      "ksql.connect.worker.config" : "",
      "ksql.sink.window.change.log.additional.retention" : "1000000",
      "ksql.readonly.topics" : "_confluent.*,__confluent.*,_schemas,__consumer_offsets,__transaction_state,connect-configs,connect-offsets,connect-status,connect-statuses",
      "ksql.udf.collect.metrics" : "false",
      "ksql.persistent.prefix" : "query_",
      "ksql.query.persistent.active.limit" : "2147483647"
    }
  }