Результаты поиска по запросу "apache-kafka"
Когда / как тема, помеченная для удаления, будет окончательно удалена?
Я выдал команду на удаление темы:
Я прочитал это, и он поднял хорошие моменты. Однако они не применимы к описанной мной схеме, в которой используются потоки Kafka: загрузка текущего состояния - выполняется с использованием KTable; Последовательные записи - это дескрипторы модели разделов Кафки и гарантии отказоустойчивости
аюсь реализовать простое подтверждение концепции CQRS / источников событий поверхПотоки Кафки [https://kafka.apache.org/documentation/streams/](как ...
если вы хотите начать с самого начала.
ли способ просмотреть содержимое сообщения, отправленного в kafka по заданной теме? Скажите что-нибудь вроде просмотра последних 5 сообщений на эту тему, есл...
Не удалось найти лидеров для Set ([TOPICNNAME, 0])), когда мы работаем в Apache Saprk
Мы используем Apache Spark 1.5.1 и kafka_2.10-0.8.2.1 и Kafka DirectStream API для извлечения данных из Kafka с использованием Spark.Мы создали темы в Кафке ...
Также существует вероятность, что такой класс появится в самой Кафке.
я есть приложение kafka streams, ожидающее публикации записей по темеuser_activity, Он будет получать данные в формате JSON, и в зависимости от значения ключа, который я хочу добавить в этот поток в разные темы. Это мой код приложения ...
Разница между session.timeout.ms и max.poll.interval.ms для Kafka 0.10.0.0 и более поздних версий
Мне непонятно, зачем нам оба
Кроме того, не делайте повторные перезапуски брокера, как это. Вы должны сначала определить, кто является Контроллером, а затем закрыть его последним.
работает пять узлов кластера с 3 зоопарками - все они являются виртуальными машинами. Мы должны часто перезагружать кластер для некоторых аппаратных исправлений. Мы написали ANSI-скрипт для отключения кластера в следующем порядке: Остановите ...
Использование Kafka в качестве (CQRS) хранилища событий. Отличная идея?
Хотя я'мы сталкиваемсяКафка раньше, я только недавно понял, что Кафка может быть использована как (основа)CQRS,eventstore.Один из основных моментов, кото...