apache-samza

0зной

3ответ

Лучшая практика Apache Kafka и Apache Samza

Я пытаюсь внедрить новую систему сообщений на основе Apache Kafka с помощью Apache Samza. У меня есть некоторые вопросы о лучших практиках и архитектуре. Первый вопрос: Я получаю сообщение об ошибке,

2зной

1ответ

Создает ли Samza разделы автоматически при отправке сообщений?

При использовании Samza-х OutgoingMessageEnvelope Чтобы отправить сообщение, используя этот формат: public OutgoingMessageEnvelope(SystemStream systemStream, java.lang.Object partitionKey,

1зной

1ответ

Модели данных потока событий

Я работаю над созданием набора схем для новой системы обработки событий и потоков, которую мы строим в моей компании, чтобы связать несколько несвязанных в настоящее время систем. Мы четко определили

0зной

2ответ

Я использую одно и то же хранилище для хранения ключей (RockDBs) в двух разных StreamTask одновременно?

Я использую Apache в качестве рамки Samza для Kafka, и мне нужно разделить одно и то же хранилище ключей с ключом RockDBs между двумя задачами. Я могу сделать это, не имея параллелизма при хранении. З

0зной

2ответ

Как подключить samza к другим системам и как писать systemFactory класса

Использование ниже конфигурации я могу подключить samza Кафке-брокер systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory systems.kafka.samza.msg.serde=json systems.kafka.con

1зной

1ответ

ContainerRequestState [INFO] Нет ожидающих запросов в очереди

Я использую кластер MapR (YARN) с тремя узлами. Я пытаюсь развернуть 6 заданий Samza в кластере для некоторой обработки потоков данных. Все задания верны. Я попытался развернуть 2-3 параллельно, и они