Описание тега confluent-cloud
1
ответ
Приложение Spring Cloud Stream Kafka Stream показывает Сброс смещения для раздела event-x со смещением 0 при каждом перезапуске
У меня есть приложение Spring Cloud Stream Kafka Stream, которое читает из темы (события) и выполняет простую обработку: @Configuration class EventKStreamConfiguration { private val logger = LoggerFactory.getLogger(javaClass) @StreamListener fun pro…
19 июл '19 в 11:46
1
ответ
Apache Kafka в Confluent Cloud - несогласованные смещения в разделенной теме и отставание потребителя
Я нахожу странное поведение при использовании Kafka в Confluent Cloud. Я создал тему со значением разделения по умолчанию: 6. Моя система состоит из приложения Java Producer, которое отправляет сообщение в эту тему, и приложения Kafka Streams, котор…
19 июл '19 в 11:14
1
ответ
Допускает ли конфлюэнтное облако развертывание настраиваемого соединителя
Confluent cloud поддерживает только следующий коннектор. Разъем для раковины GCS S3 Sink Connector Пожалуйста, подтвердите, правильно ли я понимаю. Можем ли мы развернуть собственный коннектор или компакт-диск, например debezium, в сливном облаке.
18 сен '19 в 11:52
0
ответов
Подключение к Confluent Cloud с помощью клиента AIOKafka
Я пытаюсь подключиться к своему Confluent Cloud Кластер Kafka с использованием модифицированной версии AIOKafka ssl_consume_produce.py пример в AIOKafkaрепо на https://github.com/aio-libs/aiokafka/blob/master/examples/ssl_consume_produce.py. Я настр…
03 фев '20 в 04:12
1
ответ
Ошибка установки Cloud Confluent kafka в ubuntu 18
На странице с инструкциями написано: - Установите интерфейс командной строки Confluent Cloud. Выполните эту команду, чтобы установить интерфейс командной строки Confluent Cloud.curl -L --http1.1 https://cnfl.io/ccloud-cli | ш -s - -b /usr/ местный /…
23 апр '20 в 08:47
1
ответ
Значение сообщения в Confluent Cloud некорректно декодируется
Я новичок в кафке и конфлюэнте. Я написал Продюсер, почти идентичный руководству на https://www.confluent.fr/blog/schema-registry-avro-in-spring-boot-application-tutorial/ с моей собственной фиктивной моделью. Application.yaml тоже самое. Когда я от…
10 дек '19 в 23:08
1
ответ
Запись в ConfluentCloud из Apache Beam (поток данных GCP)
Я пытаюсь написать для записи в Confluent Cloud/Kafka из потока данных (Apache Beam), используя следующее: kafkaKnowledgeGraphKVRecords.apply("Write to Kafka", KafkaIO.<String, String>write() .withBootstrapServers("<mybootstrapserver>.co…
14 янв '20 в 12:56
1
ответ
Основной сервер API Asp.net регистрирует события в Confluent Cloud Kafka при локальном тестировании, но не при размещении в службе приложений Azure.
У меня есть код, который мой Asp.net Core Web API использует для регистрации определенных событий на сервере Kafka, работающем в Confluent Cloud. Когда я запускаю сервер API на своем локальном компьютере, он может нормально отправлять и получать с п…
01 май '20 в 00:34
1
ответ
Не удалось понять api метрик сливного облака временной интервал ISO 8601
Из документа: https://docs.confluent.io/current/cloud/metrics-api.html "intervals": [ "2019-12-19T11:00:00-05:00/2019-12-19T11:05:00-05:00" ] Что это за формат интервала? Я никогда не знал, что формат времени расширяется-05:00 в дату и время 2019-12…
13 май '20 в 04:57
1
ответ
NestJs cqrs исключение и обработка ошибок в kafka
У меня небольшая проблема, Я использую Kafka с CQRS в NestJS. Мой вопрос: как лучше всего обрабатывать ошибки в процессе записи? Я отправляю запрос через веб-API в свое приложение nestjs У меня есть и событие ObjectedCreatedEvent отправляет его в ши…
13 июн '20 в 20:31
1
ответ
Kafka Consumer пустые записи
По этой теме много вопросов, но это НЕ повторяющийся вопрос! Проблема, с которой я столкнулся, заключается в том, что я попытался настроить проект SpringBoot с Java 14 и Kafka 2.5.0, и мой потребитель возвращает пустой список записей. Большинство от…
08 июл '20 в 12:10
3
ответа
Confluent Cloud Apache Kafka Consumer - Тема (и) [test-1] присутствует / отсутствует и отсутствуетTopicsFatal верно
Я новичок, пытающийся наладить взаимодействие между двумя микросервисами Spring Boot с помощью Confluent Cloud Apache Kafka. При использовании Kafka в Confluent Cloud я получаю следующую ошибку на моем потребителе (ServiceB) после того, как ServiceA…
05 дек '19 в 12:48
0
ответов
Confluent KSQL "Зарегистрируйте поток или таблицу для этой темы" не заполняет поля темы
У меня есть 4 темы, на которые я смог успешно передать данные, и их схемы выглядят хорошо. Но, щелкнув тему> "Запрос в KSQL", я заметил, что только одно из них заполняет "поля, которые вы хотите включить в свой ПОТОК". Остальные 3 отображаются пу…
30 дек '19 в 20:05
2
ответа
io.debezium.DebeziumException: тема истории БД или ее содержимое полностью или частично отсутствует
Я часто сталкиваюсь с проблемами, связанными с темой истории БД, которая создается самим соединителем. Существует временное решение (путем изменения имени темы истории базы данных), которое я пробовал, но это не лучший способ справиться с этим. Кром…
04 сен '20 в 22:34
0
ответов
Одинаковые имена таблиц в разных базах данных вызывают проблемы с реестром схемы
База данных 1 Название таблицы: Тест разъем для раковины Test-Wink белый список таблиц: общедоступный."Test" Темы: Тест-аудит База данных 2 Название таблицы: Тест соединитель раковины Test-db2-раковина белый список таблиц: общедоступный."Test" темы:…
04 сен '20 в 22:20
1
ответ
Confluent Cloud -> BigQuery - Как диагностировать причину "плохих записей"
Я мог передать данные с сервера MSSql в Topics on Confluent Cloud, но не из тем в BigQuery, выдает ошибку "Плохие записи за последний час - 65" Я смог подключить темы к bigQuery, но не смог получить данные. Формат таблицы MSSQL и BigQuery одинаков: …
12 дек '19 в 06:57
1
ответ
Как подключить реестр конфлюентных облачных схем?
Я использую управляемый Confluent кластер Kafka и службу реестра схем. Я могу управлять подключением конфлюентного облачного кластера kafka, добавляя следующие свойства в конфигурацию производителя (Scala) security.protocol ssl.endpoint.identificati…
05 апр '20 в 22:16
1
ответ
конфигурация spring-cloud-stream-binder-kafka для несанкционированной ошибки реестра Confluent Cloud Schema
У меня проблемы с настройкой подключения к Confluent при использовании spring-cloud-stream-binder-kafka. Может, кто-нибудь увидит, что не так? Когда я использую пример из https://www.confluent.io/blog/schema-registry-avro-in-spring-boot-application-…
26 май '20 в 21:36
1
ответ
Соединитель Confluent Replicator выходит из строя, потому что невозможно определить принципала по теме
Я столкнулся с проблемой при попытке репликации из одного сливного облачного кластера в другой. Я слежу за объединенной документацией о том, как это сделать, однако я постоянно сталкиваюсь с ошибкой, которая, как я полагаю, вызвана ошибкой в моей …
14 июл '20 в 18:17
2
ответа
Отсутствие проверки схемы в Confluent Cloud
Я использую конфлюэнтное облако и в настоящее время хочу, чтобы сообщения с плохой схемой не попадали в мою тему kafka. Для этого я использую функцию управления схемой confluent, где я хочу проверить, не соответствует ли сообщение указанной схеме, о…
26 авг '20 в 09:41