Я использую встроенный сервер Kafka в своем тесте, описанном здесь: https://micronaut -projects
Может кто-нибудь поделиться мне файлом yaml для создания кластера kafka с двумя брокерами kafka и...
У меня есть таблица в postgresql со столбцом с именем random_uuid типа uuid и значением по...
Похоже, что дедупликация выполняется брокером Kafka путем отслеживания сообщений на уровне раздела:...
Я запустил 3 экземпляра Hazelcast-Jet (jet-start.sh).Может видеть формирование кластера как 3 узла....
Я пытаюсь вставить данные из раздела Kafka в базу данных MongoDB с помощью Kafka-MongoDB-Connect....
Я развертываю источник JDBC Kafka Connect.Он правильно соединяется с базой данных, но я получаю...
Проходя по этому сайту, я создал Kafka Producer и Kafka Consumer https://www.tutorialkart
Прежде всего, я бы хотел кое-что понять, если я запустлю в кластере kubernetes демон-телеграф, он...
Я хочу запустить производителя Кафки, используя несколько потоков.Ниже приведен код, который я...
У меня есть два бесконечных потока данных kafka в одном задании flink, например:...
У меня 3-х узловый кластер zookeeper.10.0.0.1, 10.0.0.2, 10.0.0.3.После начала бега.10.0.0.3 был...
У меня есть случай, когда мне нужна 100% надежность, идемпотентность (без дублирующихся сообщений),...
Общий вопрос.Предположим, что в теме есть 3 раздела kafka на разных серверах (брокерах), каждый...
Я пытаюсь настроить Apache Kafka для связи между двумя виртуальными машинами с CentOS в одной сети....
Я использую spring kafka и хотел бы, чтобы в yaml приложения были указаны несколько групповых...
Spring-kafka потребитель перестает потреблять сообщения через некоторое время.Остановка происходит...
Ошибка: раздел 0 не имеет лидера.Пропустить получение смещений - но описание показывает, что лидер...
Глядя на документацию, я не уверен, что понимаю разницу между использованием close () и flush () ....
У меня есть группа потребителей, которая подписалась на ~ 3 тыс. Тем. Я использовал для мониторинга...
Микро-сервис Spring-Boot не может отправлять сообщения в тему после перезапуска kafka. Используя...
Мы пытаемся реализовать вариант использования, который описан ниже, у нас есть проблемы с...
У меня есть проект весенней загрузки, и я подключился к базовому центру событий kafka. Мне нужно...
Соединитель Kafka запускается нормально и читает поток данных в теме, однако он не записывает...
Мне известен метод metric(), доступный в Kafka API для метрик производителя. Я на самом деле...