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

Я клонировал https://github.com/confluentinc/kafka-connect-jdbc,, но у меня проблемы с пониманием,...

У нас есть хорошо настроенные узлы zookeeper и kafka. Ручной тест для создания темы и отправки...

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

ODI-1590: The execution of the script failed. ODIKM-SPARK-SYNC-10000: EKM Command Failed with...

У нас есть 3 узла кластера и 7 брокеров. Теперь мы должны создать тему и создать разделы для этой...

С 1 мая я начал использовать коннектор раковины kafka s3 (коннектор в комплекте).Работает нормально...

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

Я только начинаю использовать Kafka с Spring Boot и хочу отправлять и использовать объекты JSON....

Мы используем библиотеку Kafka Streaming для создания системы уведомлений в режиме реального...

У нас есть конвейер logstash, как показано ниже, для чтения из темы kafka в webhdfs Ввод = тема...

Я пишу приложение Kafka Consumer на основе Java. Я использую kafka-клиенты, Spring Kafka и Spring...

Я могу писать сообщения в тему Kafka, но не могу найти команду windows, чтобы получить сообщение в...

Я создал Kafka Operator, используя ibm spl code. Теперь я должен заменить ввод существующего кода...

У меня проблемы с подключением Logstash к моему экземпляру Kafka, работающему в Azure. Мой хост...

Это дополнительный вопрос к this . Мне удалось сделать следующее: Создание автономного сервиса для...

У меня есть 2 сервера, один из которых является сервером пользовательского интерфейса, а другой -...

РЕШИТЬ! спасибо, ребята, я собираюсь обновить правильный конфиг для работы. Я пытаюсь сделать свой...

Хотелось бы узнать сжатый размер сообщения в кафке. Я использую kafka 1.1.0 и java kafka-connect 1

Какие значения конфигурации вы используете для Sarama и Kafka? Кафка Версия: kafka_2.12-1.1.0.tgz...

Что произойдет, если файл журнала темы kafka будет поврежден.все ли предыдущие сообщения будут...

У меня есть тема кафки, которая получает сообщение. Теперь мой потребитель получает объект с...

Обращаясь к Spring kafka doc , я пытаюсь реализовать приложение весенней загрузки, которое...

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

Я использую выходной соединитель Filebeat -> Kafka и хотел бы построить параметр hosts и topic на...