Я перехожу по сливной ссылке , чтобы публиковать сообщения kafka об изменениях в таблице mysql....

какова задержка при динамическом создании новой темы продюсером в Kafka?Средство командной строки...

Я не вижу пример того, как использовать компонент camel-avro для создания и потребления сообщений...

Имеет ли смысл нулевой срок хранения в кафке-боркере? Мы хотим быстро переслать сообщение от...

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

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

Я использую scala 2.12 и у меня есть следующие зависимости в моем build.sbt. libraryDependencies +=...

Я пометил тему для удаления, и она там навсегда не удалялась (даже если для delete.topic.enable...

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

Я использую Кафку 2.11, получаю следующее исключение 2019-03-15 16: 41: 19.469 ОШИБКА 32539 --- [ad...

У меня есть несколько потребителей и производителей kafka (Spring boot), что, когда узел Kafka, к...

У меня проблема с назначением разделов Kafka при использовании Kafka Manager Вот мои шаги 1) У меня...

Мы отправляем сообщение с заголовками в Kafka, используя org.apache.kafka.clients.producer

У меня проблема с потребителем kafka в python, вот мой пример использования. Производитель kafka...

Я хочу, чтобы мое весеннее загрузочное приложение не запускалось при запуске, если оно не может...

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

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

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

нужна помощь.Мне нужно подтверждение того, как KSQL обрабатывает следующую ошибку: org.apache.kafka

Согласно приведенным ниже ссылкам, я должен иметь возможность установить значение retention.policy...

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

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

мы хотим установить кластер kafka и 3 сервера zookeeper kafka должен использовать серверы zookeeper...

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

Я использую kafka-connect -asticsearch с пользовательским конвертером, который расширяет стандарт...