schema-registry
schema-registry copied to clipboard
confluentinc
Confluent Schema Registry for Kafka
If a consumer tries to deserialize a record without a corresponding `SpecificRecord` class, it is deserialized into a `GenericData.Record` object (see `SpecificData.getForSchema()`). But `SpecificAvroDeserializer.deserializer()` cannot cast to `T` because `T...
Hello, I am trying to use S3 sink connector with my AWS MSK cluster (deserialization is based on AWS Glue schema registry). When I pass the options below, to connector,...
i am referring [this](https://docs.confluent.io/current/schema-registry/schema-validation.html) tutorial for validating schema. I have configured the very basic setup of confluent local. After providing `confluent.schema.registry.url=http://localhost:8081` and creating a topic with `confluent.value.schema.validation=true` i am sending...
Hello team, I'm facing a problem with the kafka-schema-registry-maven-plugin configuration in pom.xml. I want to use the execution "set-compatibility" with three schema registry url's. My configuration of schema registry url's...
I get the below exception (after which the schema-registry exits), but the exception doesn't print out the numbers of required replicas nor the number of insync replicas. This would essentially...
I am trying to send nested JSON messages and sink them using Kafka connect S3sink to parque. Whenever I nest the object too much the connector gives me the error...
For the Kafka client I'm using the following setting. ``` sasl.login.callback.handler.class=io.confluent.oauth.azure.managedidentity.OAuthBearerLoginCallbackHandler ``` With this I can provide a token e.g. for a Pod Identity in Azure. But when I want...
One of the nodes of schema registry exports `kafka_schema_registry_node_count_node_count` metric as 0, the correct value is 2. Schema registry version: `7.6.0` Steps to reproduce: 1. Spawn schema registry with 2...
Hi, ### Details First of all, issue described below belongs more to CFK operator but unfortunately posting it here as failed to find corresponding escalation point for CFK. Trying to...
- Include details about your goal Run a SpringBoot 3.2.4 reactor kafka producer with graalVM 21 native image. - Describe expected results A simple SpringBoot reactor kafka producer project is...
