Можем ли мы использовать zookeeper для хранения смещения в метамодели kafka apache
Потребитель Apache MetaModel kafka не работает для смещенного хранилища зоопарков. Я использую Apache MetaModel 5.1 и kafka версии 0.10.2.1. Я сталкиваюсь с проблемой с потребителем kafka (внутренним потребителем метамодели), так как он не потребляет никаких сообщений из темы, в моей тестовой среде смещение хранилища kafka является zookeeper. когда я пытался изменить смещение хранилища на KAFKA (в другой среде), потребитель работал нормально. На данный момент я не хочу менять смещение хранилища на kafka, так есть ли какой-либо другой способ исправить эту проблему на стороне потребителя Apache MetaModel kafka?