Мы планируем использовать сервис AWS MSK для Managed Kafka и Schema Registry, а также сервисы Kafka Connect из Confluent вместе для запуска наших коннекторов (Elasticsearch Sink Connector). Мы планировали запустить реестр схем и коннекторы в EC2....

Я новичок в кафке и конфлюэнте. Я написал продюсер, почти идентичный руководству по https://www.confluent.fr/blog/schema-registry-avro-in-spring-boot-application-tutorial/ с моей собственной фиктивной моделью. Application.yaml тоже самое. Когда я...

Я новичок, пытающийся наладить взаимодействие между двумя микросервисами Spring Boot с помощью Confluent Cloud Apache Kafka. При использовании Kafka в Confluent Cloud я получаю следующую ошибку на моем потребителе (ServiceB) после того, как...

Это вопрос о том, как подключить самоуправляемый сервер ksqlDB / ksql к сливному облаку. У меня есть объединенный базовый кластер, работающий в https://confluent.cloud/ на юге Азии GCP. В этом кластере я хочу подключить самоуправляемый...

Я хочу получить метрики Confluent cloud в Datadog, поэтому я следил за этим инструкция . Вместо использования CCLOUD_USER: $ {CCLOUD_USER} и CCLOUD_PASSWORD: $ {CCLOUD_PASSWORD} я использовал CCLOUD_API_KEY и CCLOUD_API_SECRET в качестве переменных...

Я пытаюсь написать для записи в Confluent Cloud / Kafka из потока данных (Apache Beam), используя следующее: kafkaKnowledgeGraphKVRecords.apply("Write to Kafka", KafkaIO.<String, String>write()...