Я пытаюсь составить график количества новых сообщений, полученных за единицу времени (минуты или...
Я начал работать с KSQL и вполне пережил опыт.Я пытаюсь работать с таблицей и потоком объединения и...
Я разрабатываю почтовый API с использованием node.js, который будет принимать данные в формате JSON...
У меня есть работающий экземпляр контейнера док-станции Landoop Fast Data Dev, который имеет...
Kafka Версия: 2.12-2.1.1 Я создал очень простой пример создания соединителя источника и приемника с...
В старых пользовательских конфигах есть параметр: rebalance.max.retries: Когда новый потребитель...
Мы используем Kafka 1.1x, и текущее значение по умолчанию для свойства offsets.retention.minutes...
Как обрабатывать большие сообщения в Kafka, такие как более 20 МБ и т. Д. [2019-03-13 08: 59: 10...
Использование Lagom 1.4.11, Кафка 0.11 Связь с кафкой, кажется, работает, потому что продюсеры...
У нас есть ситуация, когда нам нужно одно приложение, чтобы иметь возможность подключаться к двум...
В системах обмена сообщениями типа Тема потребитель отвечает за сообщение о начальном смещении при...
У меня установлено успешное соединение между производителем и потребителем Kafka в кластере...
По умолчанию в no-kafka есть предварительная конфигурация со значением по умолчанию 3. return...
Если у меня есть тема в Кафке, в которой есть сообщения, использующие целое число в качестве ключей
Есть ли у кого-нибудь Kafka Producer Consumer Spring Boot Example. Я пробую два или три примера...
После того, как один из узлов Kafka был уничтожен, новые брокеры Kafka не могут присоединиться к...
У нас есть сценарий использования, в котором мы хотим выдавать данные на kafka с максимальным...
Когда идентификатор клиента явно не установлен клиентским приложением kafka, как именно создается...
Мы пытаемся записать значения из темы в базу данных postgres, используя Confluent JDBC Sink...
У меня есть тема Кафки, в которой около 3 миллионов записей. Я хочу выбрать одну запись из этого,...
Я использую Voltdb. И мой вариант использования - импортировать данные из кафки в voltdb. Я...
Я пытаюсь отправить журналы приложений с помощью агента fluentd брокерам Kafka, которые имеют...
Я запускаю следующий контейнер, используя образ докера для реестра Confluent Schema.Внутри...
Каков наилучший способ реализации контроля доступа для учетной записи службы / идентификатора...
Мы используем режим Идемпотентного производителя в производителе кафки, потому что мы хотим, чтобы...