如何在SpringBoot应用程序中使用EmbeddedKsql？

<dependency>
    <groupId>io.confluent</groupId>
    <artifactId>ksql-engine</artifactId>
    <version>5.5.0</version>
</dependency>

KsqlConfig ksqlConfig = new KsqlConfig(properties);

Properties properties = new Properties();
properties.setProperty(KsqlConfig.KSQL_SERVICE_ID_CONFIG, "embedded-ksql-service");
properties.setProperty(KsqlConfig.KSQL_PERSISTENT_QUERY_NAME_PREFIX_CONFIG, "query_");
// 其他属性设置...

KsqlEngine ksqlEngine = KsqlEngine.create(ksqlConfig);

String ksql = "CREATE STREAM my_stream (id INT, name STRING) WITH (kafka_topic='my_topic', value_format='json');";
KsqlPlan ksqlPlan = ksqlEngine.execute(ksql);

List<QueryMetadata> queries = ksqlPlan.getQueryMetadataList();
for (QueryMetadata query : queries) {
    // 处理查询结果...
}

ksqlEngine.close();