вчера я установил Kafka 2.0 в Ubuntu 18.04.01 Server Edition и следовал инструкциям и пояснениям...
У меня есть проект Django, и я использую pykafka. Внутри проекта я создал два файла с именами...
Я пытаюсь использовать 10 миллионов строк CSV-файла размером (600 МБ) через Connect API. Соединение...
Я пытаюсь создать сообщения генератора пустых данных Confluent Kafka для Elasticsearch:...
Недавно у меня возникли некоторые проблемы при использовании пользовательских AIP-файлов kafka, и...
Я пытаюсь проверить Потребителей, которые подписались на тему под названием "foo". У меня нет...
Мне удалось найти несколько постов в блогах по тестам для обмена сообщениями Kafka (повсюду,...
Я запускаю Кафку локально через: докер-compose.yml zookeeper: image:...
Я пытаюсь реализовать базовый сценарий, перечитать тему с начала (хотя бы 1 сообщение), и я...
Спросите, GoldenGate будет выдвигать (Kafka) AVRO файл, нужно прочитать его и преобразовать в форму...
Я настроил kafka-connect-spooldir для использования файлов, содержащих объекты JSON, в соответствии...
У нас установлены kafka и zookeeper на одном экземпляре AWS EC2. У нас есть производители и...
KafkaProducer не может выбрать schema.registry.url, определенный в его свойствах. Как мы можем...
Я написал код производителя kafka для получения данных avro, но он показывает следующую ошибку при...
Я использую Spring и Spring Kafka для пакетной службы, которая собирает данные из Kafka до тех пор,...
Можно ли объединить более двух потоков / таблиц в KSQL? Пример: У меня есть три потока: CREATE...
У меня есть ситуация (не спрашивать), где у меня есть информация о смещении (тема, раздел,...
Предположим, что в моей теме уже есть 10 данных, и теперь я начинаю с того, что мой потребитель...
Не удается создать тему Кафки в следующих сценариях: Узел кластера Кафка: 4 Коэффициент репликации:...
Я новичок в kafka, поэтому извините, если это кажется тривиальным. Я пытаюсь использовать...
У меня есть сценарий, в котором я использую несколько производителей, которые создают сообщения....
После просмотра других ответов я все еще не могу понять это. Я могу использовать kafkaProducer и...
Я не могу использовать тему и не уверен, что с моим кодом или конфигурацией kafka что-то не так....
У меня есть приложение springboot, которое выполняет вставку в таблицу (mysql). Это в свою очередь...
Я использую spring-kafka 2.1.7 для приема сообщений JSON и хочу обрабатывать сообщения, которые не...