Можем ли мы использовать zookeeper для хранения смещения в метамодели kafka apache - PullRequest
0 голосов
/ 17 сентября 2018

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

...