Я немного озадачен тем, где хранятся смещения при использовании Kafka и Zookeeper. Похоже, что смещения в некоторых случаях хранятся в Zookeeper, в других - в Kafka.

Что определяет, сохраняется ли смещение в Кафке или в Zookeeper? А какие плюсы и минусы?

NB: Конечно, я мог бы также сохранить смещение самостоятельно в каком-то другом хранилище данных, но это не является частью изображения для этого поста.

Еще несколько подробностей о моей настройке:

Я запускаю эти версии: KAFKA_VERSION = "0.10.1.0", SCALA_VERSION = "2.11"Я подключаюсь к Kafka / Zookeeper, используя kafka-node из моего приложения NodeJS.