Я пытаюсь написать преобразователь для нашего экземпляра Kafka Connect, который берет некоторые...

Когда я пытаюсь установить kafka-connect-spooldir с confluent-hub: confluent-hub install...

Я пытаюсь создать таблицу ksql из существующей темы в kafka. Когда я запрашиваю таблицу, никакие...

Я пытался проверить нашу Кафку на наличие некоторых негативных сценариев, и один из них - очень...

Я пытаюсь получить данные в спарк по теме кафки, но я не могу этого сделать.Я пробовал учебники,...

Используя следующую ссылку, я попытался запустить kafka в Windows Настройка и запуск Apache Kafka в...

Сценарий. Сторонняя система создает сообщения для определенных пользователей и отправляет их в...

У меня около 500 разъемов, и каждый раз, когда я создаю новый, мне приходится долго ждать, чтобы...

У меня есть тема с сообщениями, и есть потребитель с именем группы как "KafkaConsumerExample".когда...

У меня есть слушатель kafka, настроенный в нашем приложении Spring Boot следующим образом:...

Я использую драйвер JDBC Apache Drill (1.14) в своем приложении, которое использует данные из Kafka

Я пытаюсь добавить пользовательский перехватчик, используя org.apache.kafka.clients.consumer

У меня очень очень большая (кол-во сообщений) тема Кафки, она может иметь более 20 МБ сообщений в...

Я пытаюсь разработать потребительский класс в Spring Boot для Kafka (kerberos).Я внес необходимые...

Я установил enable.auto.commit = Ложь Теперь я читаю некоторые данные из Кафки и почему-то не могу...

У меня есть приложение Mule и я использую коннектор Apache Kafka для подключения темы. Разъём...

Я обновил свой WSO2 EI с 6.2.0 до 6.3.0, и теперь я не могу запустить мой WSO2 с приложением log4j...

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

У меня есть следующие варианты использования: Предположим, у вас есть две микро-службы: одна...

Я пытаюсь начать новый проект с spring.boot version: 2.1.5.RELEASE и Kafka version: 2.0.1 и...

Существует полезная метрика для мониторинга отставания потребителя Kafka в spring-kafka, называемая...

Мне нужно настроить политику хранения определенной темы при создании. Я пытался найти решение, я...

Я использую AdminClient для изменения других конфигураций существующей темы kafka. Но я не могу...

Мы настроили трехузловой кластер kafka и создали тему с коэффициентом репликации 3. Мы создаем...

Настройка Таблица клиентов с полем CustomerID как nvarchar (50).(допустим, CustomerID = 100)...