Я пытаюсь отправлять сообщения MQTT на разные темы с помощью Kafka. Я использую Confluent...
Я читал о множестве дизайнерских историй, где данные попадают в хранилище (как кислотные, так и не...
Мы создаем KAFKA кластер с открытым исходным кодом kafka этой версии: https://archive.apache
Я использую последние конфликтующие образы (5.1.0) и внешние пароли OracleDB для конфигураций...
Насколько я понимаю, схема Avro будет кэшироваться локально, а потребитель будет использовать...
У меня есть одна проблема при запуске Kafka в кластере. Я объясняю это один за другим. Во-первых,...
Я пытаюсь использовать сообщения в теме кафки, используя команду ниже. Но это не работает....
Попытка понять логику периода хранения в Apache Kafka. Пожалуйста, помогите мне понять ситуацию для...
Я использую kafka_2.11-2.1.0, где я запустил сервер zookeeper, сервер kafka, создал темы и отправил...
Потребителю kafka не удалось зафиксировать смещение только для определенного раздела....
Я видел несколько похожих вопросов следующим образом: www.quora.com / Что такое «фактическая роль»...
Я обрабатываю поток Kafka с помощью Flink SQL, где каждое сообщение извлекается из Kafka,...
Я работаю с кластером kafka в AWS, я хотел бы дать каждому брокеру CNAME, чтобы я мог ссылаться на...
Я впервые использую Кафку.Я следовал этому учебнику.После запуска Zookeper я запустил сервер kafka
В весеннем загрузочном проекте с использованием шаблона kafka для отправки сообщения import org
У нас работает пять узлов кластера с 3 зоопарками - все они являются виртуальными машинами.Мы...
Я исследую Kafka, чтобы оценить его пригодность для нашего варианта использования.Не могли бы вы...
Как я понимаю, Kafka, идентификатор группы потребителей и THAT ALONE определяют, принадлежат ли N>...
у нас есть один потребитель, который потребляет данные из кафки с 5 разделами.у потребителя есть 5...
Я использовал KSQL для создания потока и агрегированной таблицы из этого потока. {...
У меня есть потоковое задание, реализованное поверх Apache Beam, который читает сообщения от Apache...
Я подключаюсь к нескольким кластерам Kafka из моего кода, и оба кластера kafka требуют keytab и...
Я использую Spring и Kafka, я делаю HTTP-запрос POST, как показано ниже, и отправляю некоторую...
При попытке настроить вновь созданную тему kafka, используя java kafka adminClient, значения...
Я настраиваю Kafka Connect для копирования данных из Kafka в базу данных Мне нужно поместить...