Mine - это приложение Springboot. В моем коде упругого поиска есть kafka-потребители.Итак, при...

Я создаю набор микросервисов в среде Spring Boot, каждый из которых интегрируется с Kafka для...

Я разработал производителя Kafka, который отправляет сообщения асинхронно. Для меня такой...

Я пытаюсь создать приемник, который будет сохранять данные XML в базе данных в виде строки, однако...

Здесь https://docs.confluent

Мне известно, что максимальное количество активных потребителей в группе потребителей - это...

У меня есть приложение весенней загрузки с несколькими экземплярами (несколько слушателей и...

Я пытаюсь использовать соединитель kafka для записи данных в Hive с форматом OCR с шины Kafka....

В развертывании Kafka пользовательская логика разделителя тем используется для маршрутизации всех...

Я использую Кафку с веточкой Java. Я вижу, что сообщения, которые создаются только один раз,...

Создан исходный соединитель JDBC catalog.pattern = test_01 Конфигурация исходного соединителя {...

Существует ли способ автоматической загрузки (нескольких) разъемов Kafka Connect при запуске Kafka...

Я пишу тестовый класс, который имеет несколько методов, которые требуют Kafka.Каждому из них...

Мое приложение весенней загрузки запускает маршрут Camel, который используется из концентратора...

Я пытаюсь подключиться к Azure Data Explorer, используя Confluent Kafka Sink Connector

Существует внешняя база данных, к которой у нас есть доступ к 7 просмотрам.Каждое утро мы хотим...

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

Целью настройки transactional.id для продюсера, в моем понимании, является защита от производителя...

Я настраиваю производителя на 10-секундный таймаут, используя свойство transaction.timeout.ms....

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

Недавно мы начали использовать Kafka, и я пишу потребительское приложение Kafka, использующее...

Рассмотрим этого потребителя Kafka, который получает данные из темы, буферизует их в...

Я пытаюсь вставить данные с помощью коннектора Kafka JDBC Sink, но мне возвращается это исключение....

Команда подключения к debezium kafka: docker run -it --rm --name connect -p 8083:8083 -e GROUP_ID=1...

Попытка использовать Flink для чтения потока Kafka сериализованных данных "avro", например:...