Блог

При использовании rest api с KsqlDB при попытке создать поток с определением я не вижу ошибки, и он не создает поток.

   "sql": "CREATE STREAM  user_test_EKS(userId DOUBLE, name VARCHAR)  WITH (kafka_topic='user_EKS', value_format='json', partitions=1);",
  "streamsProperties": {
      "ksql.streams.auto.offset.reset": "earliest"
  }
}
 

Однако это тело запроса работает так, как ожидалось

 {
  "ksql": "CREATE STREAM pageviews_home AS SELECT * FROM pageviews_original WHERE pageid='home'; CREATE STREAM pageviews_alice AS SELECT * FROM pageviews_original WHERE userid='alice';",
  "streamsProperties": {
    "ksql.streams.auto.offset.reset": "earliest"
  }
}