Кафка (v1.0) удалил сегмент журнала из темы, хотя эта тема настроена на бесконечное хранение...

Я вижу состояние моего разъема, и у меня есть это исключение org.apache.kafka.connect.errors

Я использую jmxtrans для мониторинга kafka mirrormaker, но у меня, похоже, проблемы с форматом json...

Я новичок в лазурной функции и Кафке. Хотелось бы узнать, можно ли вызвать функцию лазури при...

Я разработал проект, который читает сообщения от Кафки и обрабатывает их в Storm. Тем не менее, я...

Можно ли безопасно разделить две темы метаданных Apacke Kafka Connect, config.storage.topic и...

В чем разница между объектами KafkaSpout и KafkaBolt? Обычно KafkaSpout используется для чтения...

Я пытаюсь определить URL для SalesForce, так как он связан с настройкой провайдера Kafka. Я...

Что такое зависимость Maven для импорта org.apache.storm.kafka.bolt.KafkaProducerTopology Я...

мы отправляем данные из DB2 (таблица-1) через CDC в темы Kafka (тема-1). нам нужно согласовать...

Мы используем pykafka 2.3.1 и время от времени наблюдаем, как продюсер зависает. Сообщение об...

Я использую spring-kafka 1.1.3.RELEASE и kafka-clients 0.10.0.0, и я хочу установить...

Когда раздел назначается производителем с использованием номера. Например, kafkaTemplate.send(topic...

Я создал проект Java для передачи данных на сервер Kafka. и этот проект Java Maven не содержит...

Я запускаю kafka_2.11-2.0.0 на машине с Ubuntu 16.04. Создал тему и выдал ей несколько сообщений из...

Я скопировал рабочую среду docker / kafka со своей локальной машины Ubuntu на облачную виртуальную...

Я пытаюсь установить Apache Kafka на свой компьютер. Я скачал новейшую версию 2.12-2.0.0. Я хочу...

У нас есть микросервисный ландшафт, каждый из микросервисов разработан с загрузкой Spring....

Я попытался установить ibm-eventstreams-dev v 0.1.2 на мой Mac. После того, как я установил события...

Доброе утро. Прежде всего, я создал рой докеров с двумя физическими хостами и оверлейной сетью. На...

мы используем кафку 1.1.0. log4j.properties похож на log4j.appender.kafkaAppender=org.apache.log4j

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

Как бы кафка реагировала на следующие сценарии? У меня есть 2 брокера с разными конфигурациями (ЦП...

В моем приложении я использую spring-kafka для получения сообщения от сервера kafka, но от...

Мы используем Кафку 1.11 наша системная задача состоит в том, чтобы удерживать низкую задержку на...