Мы используем кластер Kafka с 3 узлами, в общей сложности 151 тема с 1 разделом для каждой темы. И...
Я пытаюсь проверить состояние транзакции между Kafka и вызовом БД (Postgres), когда в случае сбоя...
Я использую Kafka версии 2.2.0cp2 через Rest Proxy (в контейнере Docker). Мне нужно, чтобы...
Можно ли удалить вложенное поле с помощью SMT с подключением Kafka? Я знаю, что следующее прекрасно...
Я получаю эту ошибку при создании KafkaProducer с пакетом kafka-python: [ERROR]...
Как я знаю, потребитель Kafka перейдет в реестр схем для извлечения и кэширования схемы данных для...
Я использую kafka-python в проекте django. Инициализировал производителя в файле settings.py....
У нас есть kafka 2.12_2.2.0, который в настоящее время работает с zookeeper 3.4.13 Мы пытаемся...
Я следил за Kafka Quickstart за «Настройка кластера с несколькими брокерами» на одной машине....
Мы собираемся использовать Kafka Connect JDBC Source Connector для получения данных из баз данных...
У нас есть микросервисная архитектура, и мы хотим публиковать события в темах Kafka для...
Привет. Весь этот вопрос является продолжением вопроса здесь . Теперь у меня есть одноузловой...
Где находится значение max.partition.fetch.bytes в клиенте Kafka? Я не нашел ни одного имени...
Могу ли я создать свой собственный каталог в s3, используя конфлюент S3SinkConnector? Я знаю, что...
Я использую Kafka Connect в распределенном режиме. Странное поведение, которое я наблюдал несколько...
Это бизнес-требование, чтобы все сообщения, которые я использую в теме kafka, содержали печать...
Я недавно обновил конфигурацию log.retention.hours в файле server.properties с 168 до 730 часов....
Когда я бегу локально, я вижу, что kafka.consumer. собираются. Пока при развертывании моего сервиса...
У меня есть следующие настройки: Spring Boot Library 1 отправка сообщений брокеру Apache Kafka (как...
Я использую транзакцию Spring kafka для своих приложений производителя и потребителя. Требование на...
Я искал документацию о том, где KSQL запрашивает хранилище и таблицы. Например, поскольку KSQL был...
У меня есть сценарий использования, в котором метрики будут записываться в разделы kafka, и оттуда...
Я использую Задачу Мойки Кафки для чтения записей из темы Кафки. Метод put () в SinkTask - это...
У меня есть тема с 50 разделами и группа потребителей, слушающая эту тему. Я использую приведенную...
Я использую Kafka Streams в критически важном приложении, и у меня возникают проблемы, когда...