Какова цель createDrainingControl? - PullRequest
0 голосов
/ 23 апреля 2019

Я читал документацию по Альпакке. Читая пользовательский API Kafka, я наткнулся на createDrainingControl (), мне было интересно, для чего используется эта функция? Я понимаю, что это используется для слива и остановки потока, но зачем нам останавливать поток, если мы постоянно потребляем сообщения от Kafka MQ?

1 Ответ

1 голос
/ 24 апреля 2019

В конце концов вам нужно будет развернуть новую версию приложения, где вам придется остановить текущее приложение и запустить новую версию. Это всегда можно сделать, убив старое приложение, но это увеличивает количество повторов, тайм-аутов или ошибок, все в зависимости от того, что делает ваше приложение.

Если вместо этого вы корректно остановите приложение, сначала опустошив поток, это уменьшит количество этих нарушений.

...