Kafka Streams: Каковы негативные последствия медленной пунктуальной работы?
Вы не можете, нет способа определить, удалено ли приложение, и Apple не отслеживает удаленные приложения, к которым вы, как и разработчик, может получить доступ.
1 ответ
Если ваша логика пунктуатора работает медленно, как несколько минут, поток Kafka не будет потреблять новые сообщения от определенного раздела (на котором выполняется пунктуатор), пока пунктуатор не завершит выполнение. также долго работающий пунктуатор не должен вызывать перебалансировку (перебалансировка может произойти по другим причинам)
, влияет ли пунктуатор на одном разделе на другие, зависит от того, запускаете ли вы приложение на одном узле или на нескольких, а также на num.stream.threads свойство, которое вы могли бы указать для Kafka Streams. если ваше приложение работает на одном узле, поток Kafka будет использовать только один поток для всех разделов (по умолчанию num.stream.threads равен 1). так что в этом случае пунктуатор на определенном разделе также блокирует все остальные разделы. но если у вас есть несколько экземпляров приложения и / или num.stream.threads больше 1, если некоторые из пунктуаторов работают быстро, то такие разделы не будут затронуты длительными пунктуаторами в других разделах.