Я звоню Кафке, используя доверенный прокси REST API.Я читаю CSV-файл, создаю объект из всех...
У меня есть ситуация, когда я разрабатываю спокойный веб-сервис, где мне нужно отправить сообщения...
Я устанавливаю сервер в nodejs, который использует kafka. Для этого я использую kafkaJS. Проблема в...
Я пытаюсь опубликовать сообщение в теме движка Kafka tb.rule, чтобы цепочка корневых правил...
Хотя для поля определено значение по умолчанию, kafka-avro-console-producer полностью его...
Я запускаю kafka на одном узле, я хочу увидеть поведение kafka Producer, когда я выключаю свой...
Я использую приведенный ниже код API производителя для записи сообщений в тему Kafka, но не удается...
Существует ли минимальная скорость сообщения в Гбит / с, необходимая для выбора Kafka для потоковой...
У меня есть сценарий, где я вижу другое поведение.Как и в общей сложности 3 различных сервиса...
Я написал небольшой код для нестандартного производителя в Kafka, используя scala, и он выдает...
У меня есть производитель кафки с 4 темами. Когда я загружаю CSV в соответствии с типом CSV, я...
Мы используем Spring Cloud Stream для Kafka и ищем семантику «Однажды». У нас есть одно решение,...
Я пытаюсь прочитать данные JSON из Kafka, используя следующий код: @source(type = 'kafka'...
В моем понимании, когда я хочу отправить фильм (4 ГБ) брокеру Kafka, один производитель отправит...
Производитель A пишет сообщение брокеру A (раздел 1), а производитель B пишет то же сообщение...
В одном из моих вариантов использования я пытаюсь создать конвейер всякий раз, когда я отправлял...
У меня был td-agent, без проблем отправляющий сообщения в очередь Kafka.Но теперь я получаю...
Я пытаюсь отправить сообщения Кафке с транзакцией. Итак, я использую этот код: try...
Я пытаюсь создать анализ больших данных, используя Kafka, Python и Twitter. У меня есть поток...
Есть ли способ заставить потребителя прочитать последнюю версию?Например, допустим, у меня есть...
Допустим, у меня есть два потребителя - С1 и С2 в одной группе потребителей. Есть 10 сообщений на...
Я новичок в Kafka и пытаюсь проверить мой дизайн. Ниже то, что у меня есть. У меня есть один...
У меня есть несколько списков, которые я хочу отправить через производителя Kafka. listA [1,2,3]...
Это вопрос из двух частей.У меня есть список, в котором будет один элемент в списке...
Я использую пружинную кафку с идемпотентной конфигурацией производителя: это мои реквизиты...