Вывод из клиента zookepeer: [zk: s1:2181(CONNECTED) 1] ls /brokers/ids [1, 2, 3] [zk:...

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

Я создал конвейер kafka для копирования таблицы sqlserver в s3 Во время слива я пытаюсь...

В последнее время у нас возникают проблемы с производительностью наших потребителей и...

Этот вопрос относится к Spring Kafka, связанному с Apache Kafka с потребителем высокого уровня:...

Я использую для настройки bootstrap.servers в моих приложениях производителя / потребителя / потока...

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

Я использую соединитель Debezium Postgres и обнаруживаю, что соединитель не захватывает столбцы...

Мне нужно создать контейнер Docker для проекта, включающего потоковую передачу данных с...

У меня есть часть Java-приложения, которое записывает закодированный AVRO-объект в тему Kafka. Я...

Из того, что я могу сказать, с помощью десериализации Flink AVRO вы можете создать поток...

Я установил retention.ms = 3600000 с помощью приведенной ниже команды, но все равно на диске много...

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

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

Мы успешно использовали прием данных MySQL - kafka с использованием автономного коннектора jdbc, но...

pom.xml <?xml version="1.0" encoding="UTF-8"?> <project...

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

У меня есть приложение Flink, которое использует FlinkKafkaConsumer. Я заинтересован в получении...

Я оцениваю Apache Kafka для публикации некоторых потоков событий (и команд) между моими службами,...

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

Я пытаюсь использовать точный код, предоставленный здесь, для отправки / получения данных с Kafka...

Я использую kafka v.0.10.2 на своем кластере. Я могу нормально создавать сообщения, используя v.0.8

Мы успешно использовали загрузку данных mySQL - kafka с помощью автономного коннектора jdbc, но...

Я использую docker-compose.yml для настройки многослойного веб-приложения. пакет: image:...

max.poll.records был недавно изменен на 500 в конфигурации потребителя kafka, но мне интересно, как...