i pushed querys for all basic osquery table to kafka ,but for the other alert querys and event querys,i want to split into diferent pipelines.