是否可以从数据库中按需查询数据（例如Mongo DB）通过Kafka连接器？
例如，假设我有一个汽车集合，其中包含以下数据-

{
       Brand: Mahindra,
       Model: XUV300
}
{
       Brand: Mahindra,
       Model: XUV500
}
{
       Brand: TATA,
       Model: Nexon
}

字符串
我想通过Kafka连接器获取所有Mahindra模型。我应该怎么做才能在我的某个Kafka主题中查询和获取这些数据？
其目的是通过Kafka控制一切，而不是通过代码直接与db交互。尝试通过Kafka doc和Google，但没有找到任何解决方案