Мы используем версию Hazelcast Jet 0.4 для чтения сообщений из Kafka Source, обработки сообщений и записи в Kafka.
Поскольку Кафкой управляет внешняя команда, мы не можем контролировать различные исключения, генерируемые в Кафке.
Например, мы получаем следующее исключение: Не удается завершить фиксацию, поскольку группа уже перебалансировала и присвоила разделы
Когда мы получаем эту ошибку, экземпляр Hazelcast Jet отключается. Таким образом, наше приложение становится непригодным для использования, и мы должны перезапустить приложение.
Мы рассматриваем возможности автоматического перезапуска экземпляра Jet во время этих ошибок.
Спасибо за вашу помощь!