Результаты поиска по запросу "apache-kafka"
Кроме того, нет хорошего способа узнать, когда микропакет полностью обработан вашим приложением, особенно если у вас несколько приемников.
ользую структурированную потоковую передачу со Spark 2.1.1. Мне нужно применить некоторую бизнес-логику для входящих сообщений (из источника Kafka).по сути, ...
если вы хотите начать с самого начала.
ли способ просмотреть содержимое сообщения, отправленного в kafka по заданной теме? Скажите что-нибудь вроде просмотра последних 5 сообщений на эту тему, есл...
kafka.apache.org/0101/documentation.html#upgrade_1010_notable
ал другие темы и обошел проблему с помощью нового идентификатора группы, однако я хотел бы понять, что может вызвать это.У меня есть тема с 16 разделами, я у...
Вы проверяли это? Я думаю, что он добавляет новые файлы в каталог / путь
некоторой обработки у меня есть DStream [String, ArrayList [String]], поэтому, когда я записываю его в hdfs, используя saveAsTextFile, и после каждого пакета...
) », В которой рассказывается, почему Kafka не является конкурентоспособной, но дополняет решения по интеграции и обмену сообщениями (включая ActiveMQ), и как интегрировать обе системы.
отаю надАпач Кафка, Я хочу знать, какой из них лучше:Кафка или жеActiveMQ, В чем главное отличие этих двух технологий? Я хочу реализоватьКафка весной MVC.
Спасибо, Рэндалл ... Это очень помогло ..
лкиваюсь с вопросом ниже об изменении некоторых свойств, связанных с kafka и перезапуске кластера.
Клиент Blizzard / node-rdkafka - ваш лучший выбор, так как он включает librdkafka и поддерживает offsetsForTimes ()
ли использовать сообщения от Кафки в течение периода времени, в течение которого они были приняты?пример: Я хочу, чтобы все сообщения попадали в тему между 0...
Супер, спасибо Михал
ользую поток kafka и пытаюсь материализовать KTable в тему.Это работает, но, кажется, это делается каждые 30 секунд или около того.Как / когда Kafka Stream р...