澄清：请注意，这个问题与这个问题不同：如何使用spring云流kafka和每个服务的数据库实现一个微服务事件驱动架构
这一个是关于使用kafka作为唯一的存储库（事件），不需要db，另一个是关于每个服务使用一个数据库（mariadb）+kafka。
我想实现一个事件源架构来处理分布式事务：

OrdersService <------------> | Kafka Event Store | <------------>PaymentsService
                subscribe/                           subscribe/
                   find                                 find

ordersservice接收订单请求并将新订单存储在代理中。

private OrderBusiness orderBusiness;    

@PostMapping
public Order createOrder(@RequestBody Order order){
    logger.debug("createOrder()");
    //do whatever
    //Publish the new Order with state = pending
    order.setState(PENDING);
    try{       
       orderSource.output().send(MessageBuilder.withPayload(order).build());
    }catch(Exception e){
        logger.error("{}", e);
    }
    return order;
}

这是我的主要疑问：如何查询Kafka经纪人？假设我想按用户/日期、状态等搜索订单。