В 0.8.2 кажется, что фиксация смещений больше не имеет тех проблем с производительностью, которые были раньше (http://blog.confluent.io/2014/12/02/whats-coming-in-apache-kafka-0-8-2/). Использует ли это потребитель высокого уровня или это отдельный API? т.е. могу ли я безопасно начать коммиты намного чаще при использовании потребителя высокого уровня?
Использует ли потребитель высокого уровня новое управление смещением в Kafka 0.8.2?
Ответы (1)
Я пока не могу говорить о сравнении производительности с хранилищем смещений Zookeeper, но потребитель высокого уровня поддерживает сохранение смещений в Kafka с 0.8.2. Вы можете настроить его, установив для свойства offsets.storage значение kafka. Вы также захотите установить для свойства dual.commit.enabled значение true во время процесса миграции для любых существующих групп потребителей, которые в настоящее время фиксируют смещения в Zookeeper.
См. часто задаваемые вопросы по Apache Kafka для подробности о переносе.
person
Patrick
schedule
02.05.2015
