apache-kafka

Вопрос или проблема Я развернул кластер Kafka strimzi в своей локальной среде. Я также развернул strimzi connect в своей локальной среде. Я хочу запустить JDBC Source Connector, чтобы читать данные из Postgresql и записывать их в тему.

Вопрос или проблема Я пытаюсь отправить сообщения в две разные темы Kafka, используя KafkaSender из Reactor Kafka. Под двумя разными темами Kafka я имею в виду: Есть тема под названием “first_topic” в кластере kafka-first-broker.

Вопрос или проблема Я установил кластер Kafka с использованием протокола KRAFT, и во время аутентификации ACL я столкнулся с проблемой ‘Не удалось настроить SaslClientAuthenticator’. Ниже представлена моя конфигурация.

Вопрос или проблема У меня есть 2 приложения SpringBoot, развернутых в AWS, APP1 управляет автомобилями, и для каждого нового добавленного автомобиля он создаст 2 темы kafka, которые будут использоваться только для этого автомобиля (тема A для событий APP1 ->

Вопрос или проблема Я создал стек docker swarm. В стеке два сервиса: приложение springboot3 и kafka. Я использовал последний образ docker apache/kafka. введите описание изображения здесь Это мой compose.yml, дополнительно, kafka и приложение springboot

Вопрос или проблема Я использую Event Hubs для брокерства событий, публикуемых из системы, использующей нативный клиент C# для Event Hubs. Кроме того, я использую клиент Kafka в Databricks для публикации событий в тот же хаб. Порядок важен, поэтому я

Вопрос или проблема Я сталкиваюсь с исключением ProducerFencedException при попытке синхронизировать события между Kafka и базой данных PostgreSQL, используя Spring Kafka. События отправляются в Kafka, и база данных обновляется успешно, и я могу видеть

Вопрос или проблема У меня есть требование, где мне нужно создать несколько записей с разными ключами, используя привязки Spring Cloud Kafka. @Getter @Setter public class Transaction { private String paymentRef; private String List<

Вопрос или проблема Я написал код Kafka Consumer с использованием Apache Kafka и интегрировал его в свое приложение Camel, но при попытке развернуть образ в кластере Kubernetes возникает следующая ошибка для маршрута: Ниже приведен мой код: `@Override

Вопрос или проблема В настоящее время я работаю над приложением Kafka Streams, где пытаюсь настроить GlobalKTable и KStream, используя одну и ту же тему (sampleTopic). Однако при попытке запустить приложение я сталкиваюсь со следующей ошибкой: Не удалось создать [org.

Вопрос или проблема Я включил CDC в своем экземпляре Neo4j и настроил тему Kafka для прослушивания изменений данных в базе данных Neo4j. Согласно документации Neo4j, данные событий должны быть в формате пар “ключ-значение”

Вопрос или проблема В kafka 2.6.1 есть топик под названием test с двумя репликами и 30 партициями. Теперь партиции расширены до 40. Однако было обнаружено, что емкость диска изменяется в процессе расширения. После проверки топика оказалось, что есть только

Вопрос или проблема Не могу настроить advertised.listeners для AWS MSK Kafka, может кто-нибудь объяснить, что делать дальше? Как это сделать? Для брокера 1 bin/kafka-configs.sh –bootstrap-server b-1.kaffka.6r40l0.c4.kafka.eu-central-1.amazonaws.com:9094 –

Вопрос или проблема Я пытаюсь настроить обработку ошибок для слушателя батчей таким образом, чтобы, если одна запись не удается обработать, весь батч отправлялся в топик мёртвых писем (с некоторым дополнительным логированием).

Вопрос или проблема У меня есть данные, такие как: Одно сообщение Kafka: [{"source": "858256_6052+571", "numericValue": null, "created": 1725969039288, "textValue": "mytestData"}] Еще одно сообщение Kafka: [{"source": "858256_6052+571", "numericValue"