Я пытаюсь создать разные темы в aws kinesis, но не могу найти способ сделать это .. Я пытался...
Справочная информация: Я пишу потоковый процессор kafka, который получает несколько событий, он...
Как часть требования, мы продолжаем использовать Kafka connect для передачи данных в нашу базу...
Чтобы использовать данные из Kafka, у нас может быть несколько потребителей по теме, полностью...
ОБНОВЛЕНИЕ: Оказалось, у меня проблема с моими портами в Docker. Не уверен, почему это исправило...
У меня есть два кластера кафки.Мне нужно реализовать вид синхронизации между ними с помощью...
У меня есть данные в теме Kafka, которые я хочу сохранить на своем озере данных. Прежде чем...
Наш кластер AWS MSK не создает автоматически темы, когда продюсер впервые публикует сообщение для...
Я пытаюсь отправить данные в эластичный поиск, который происходит из раздела kafka с Logstash, но у...
Я не смог найти ответ в API транзакции.Я думаю, что, вероятно, невозможно рассмотреть дизайн под...
У меня есть настройка темы Kafka, и я пытаюсь создать внешнюю таблицу в Hive для запроса потока...
У меня есть файл .zip, и я хочу извлечь его с помощью Streamsets и поместить данные (.zip) в Kafka....
Я хочу убить своего распределенного работника Kafka Connect, но я не могу (или не знаю, как)...
Я использую клиентский клиент Kafka для моего POC, теперь мне нужно перенести клиентский клиент...
Я хочу опубликовать данные нескольких таблиц в одной и той же теме Kafka, используя приведенную...
Я использую <dependency> <groupId>org.apache.kafka</groupId>...
Я пытаюсь получить метрики Кафки на уровне темы в Java.Документы kafka показывают, что я могу...
Я настраивал новый кластер для Hyperledger Fabric на EKS. Кластер имеет 4 узла кафки, 3 узла...
Я разрабатываю модуль чата для веб-платформы, используя протокол веб-сокета и STOMP в качестве...
Я отправляю простое сообщение в тему Kafka с моего API-интерфейса Spring boot rest, размещенного на...
Я использую официальный соединитель Kafka RabbitMQ для получения сообщений JSOn из экземпляра...
Кажется, название описывает мои проблемы. Почему .timeindex inf kafka хранит относительное смещение...
Предположим, что количество разделов является фиксированным для темы.И предположим, что я...
Я хотел бы протестировать Spring Cloud Stream с регистрацией Confluent Schema и эволюцией Avro...
Я хочу установить свойство acks = all для моего производителя в моем приложении весеннего облачного...