apache元模型kafka使用者不适用于存储。我使用的是apachemetamodel5.1和kafka版本0.10.2.1。我面临kafka consumer（元模型内部使用者）的问题，因为它不使用来自我的测试环境kafka偏移存储的任何消息。当我尝试将偏移存储更改为kafka（在不同的环境中）时，consumer工作得很好。到目前为止，我不想将偏移存储更改为kafka，那么在apache元模型kafka用户端有没有其他方法来解决这个问题？