trident

4зной

2ответ

Топология бури Trident с Kafka: Получена непредвиденная ошибка в кортеже

У нас есть топология Trident, которая потребляет и производит до kafka, используя кафка-шторм OpaqueTridentKafkaSpout и TridentKafkaState. Все отлично работает, когда работает на нашем производство шт

1зной

1ответ

Как узнать, успешно ли совершена транзакция в Apache Storm Trident

Я пытаюсь начать работу с Storm Trident и настроить топологию с IOpaquePartitionedTridentSpout и под управлением OpaqueMap. Тем не менее, я изо всех сил стараюсь узнать, как можно сообщить, что транза

1зной

1ответ

Сторм Trident и Спарк Streaming: распределенная партия блокировки

После делать много чтения и построения ДОУ мы все еще не уверены, является ли Бури Trident или Спарк Streaming может обрабатывать наш случай использования: У нас есть входящий поток данных датчиков дл

0зной

1ответ

Как написать топологию трезубца без агрегатов?

Я хотел бы обрабатывать кортежи в пакетах, для которых я думаю об использовании Trident API. Однако никаких операций, которые я выполняю пакетами здесь. Каждый кортеж обрабатывается индивидуально. Все

0зной

1ответ

Что произойдет, если перезапуск кафки перезапустит штормовой трезубец?

Скажите, что носик кафки достал некоторые сообщения, и в это время задача носика перезапускается. Будут ли потеряны сообщения? Я стартер на трезубец, и мой вопрос в том, что трансактный транзакционный

0зной

1ответ

Поиск в базе данных: Как использовать CachedMap в Trident

Как использовать CachedMap в Trident. Мой случай использования таков, что я буду делать некоторую базу данных и хочу сохранить эту информацию в кеше или состоянии трезубца. В следующий раз, когда я по