apache-kafka - 我们可以使用zookeeper在kafka apache元模型中存储偏移量吗

Question

Apache MetaModel kafka 消费者不适用于动物园管理员偏移存储。我正在使用 Apache MetaModel 5.1 和 kafka 版本 0.10.2.1。我面临 kafka 消费者（元模型内部消费者）的问题，因为它不消耗来自主题的任何消息，我的测试环境 kafka 偏移存储是 zookeeper。当我尝试将偏移存储更改为 KAFKA（在不同的环境中）时，消费者工作得很好。到目前为止，我不想将偏移存储更改为 kafka，那么有没有其他方法可以在 Apache MetaModel kafka 消费者端解决这个问题？

标签： apache-kafkametamodelapache-metamodel