我使用的是数据登山者提供的Cassandra源连接器。缺少的是kql中where子句的用法。我希望以这样一种方式编写kql，它将根据列的值发送不同主题的数据。例如，如果我有以下记录：

[
  {
    id:1,
    store:"102"
  },
  { 
    id:2,
    store:"105"
  },
  {
    id:3,
    store:"102"
   },
   {
    id:4,
    store:"105"
   }
 ]

然后我想把store=105的数据发送到一个主题，把store=102的数据发送到另一个主题。