Я использую низкоуровневый API-процессор.У меня есть тема с 6 разделами.В классе, который реализует Processor<K,V>
, я определил некоторые переменные класса (нестатические).Я понимаю, что будет 6 заданий.Когда мы запускаем потоковое приложение, я вижу, что создается 6 объектов класса, который реализует Processor<K,V>
.Можем ли мы связать эти экземпляры объектов с задачами?Во время перебалансировки я предполагаю, что разделы могут переключаться с одной задачи на другую либо в отдельном потоке, либо в другой экземпляр.Если это так, будет ли создан новый объект класса, который реализует Processor<K,V>
для раздела, который был переназначен в другом потоке или экземпляре, и метод close будет вызван для существующего объекта, соответствующего этому разделу?