У меня есть сценарий, в котором мне нужно изменить структуру сообщения, которое я получаю от...
Я использую Dockerized Kafka и написал одну потребительскую программу Kafka.Он отлично работает,...
Я новичок в Apache Kafka и могу отправить сообщение (в формате JSON) от отправителя, но не могу...
Я использую Kafka (kafka-python) версии 3.0.0-1.3.0.0.p0.40.Мне нужно настроить потребителя для...
Я пытаюсь развернуть приложение для мониторинга отставания, написанное на Scala, которое использует...
Я пытаюсь скопировать данные из таблицы в oracle db и пытаюсь поместить эти данные в тему кафки.Для...
Я пытаюсь подключиться с внешнего клиента (моего ноутбука) к брокеру в кластере Kafka, который я...
Простой вопрос: Предположим, у меня есть тема с 3 разделами: Тема: StateEvents P1, P2 и P3. Давайте...
Пример: {"id":"1","firstName":"abc"...
Насколько я могу судить, глядя на код, этот класс кажется поточно-безопасным, с синхронизацией в...
сценарий использования: использовать сообщения, отправленные в тему, и сохранять их в AWS S3 . Для...
У меня есть простой конвейер, использующий apache nifi, и я хочу опубликовать некоторые сообщения в...
В одной теме 20 разделов, почти у каждого есть более 20 000 файлов сегментов журнала, большинство...
Я пытаюсь отключить TLS 1.0, 1.1 для кластера Kafka. Я добавил эту конфигурацию в файл kafka /...
Я развернул брокер kafka на сервере (kafka-версия 2.11-0.10.1.1), и с моей локальной машины...
Я обрабатываю сообщения kafka с использованием релиза spring boot 2.0.2 и spring kafka 2.1.10 и...
Я подключаюсь к базе данных Microsoft SQL Server, используя стандартный соединитель Confluent JDBC...
Если у меня есть объект JSON, и я хочу преобразовать его в поток байтов (для Kafka), это всегда тот...
Я имитирую производителя кафки для чтения из файла.Я хотел бы читать из файла каждые 15 минут, так...
В моем файле свойств исходного соединителя kafka jdbc есть следующий SQL-запрос: query=SELECT *...
У меня есть приложение, которое получает большое количество запросов GET (около 250000 за 5 минут)
Я слышал, что если я использую Kafka Consumer на основе Java, я могу выставлять из него JMX-метрики...
Я пытаюсь преобразовать конфигурацию kafka, не поддерживающую стойку, в стойку.Моя установка...
Я создал тему "test_topic_02" и вручную записал данные в брокер, который успешно завершился.Но...
Скажем, у нас есть два ЦОД DC1 и DC2.Я зеркально отражаю данные Кафки от DC1 до DC2, используя...