Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add avro.serializer.normalize.schemas to AvroSerializer properties validation #2058

Open
8 tasks done
fennnan opened this issue May 26, 2023 · 1 comment · May be fixed by #2126
Open
8 tasks done

Add avro.serializer.normalize.schemas to AvroSerializer properties validation #2058

fennnan opened this issue May 26, 2023 · 1 comment · May be fixed by #2126

Comments

@fennnan
Copy link

fennnan commented May 26, 2023

Description

When adding a value to NormalizeSchemas of AvroSerializerConfig, the AvroSerializer fails with AvroSerializer: unknown configuration property avro.serializer.normalize.schemas even it uses it after the validation

How to reproduce

Set a true value to an AvroSerializerConfig and then use it for create a specific AvroSerializer
`
var schemaRegistryConfig = new SchemaRegistryConfig
{
Url = "schemaRegistryUrl",
};

var avroSerializerConfig = new AvroSerializerConfig
{
// optional Avro serializer properties:
BufferBytes = 1024,
AutoRegisterSchemas = false,
SubjectNameStrategy= SubjectNameStrategy.Record,
NormalizeSchemas = true,
};
var avroSerializer = new AvroSerializer(schemaRegistry, avroSerializerConfig);
`

Configuration

Apache Kafka version any
Confluent.Kafka library 2.11
Windows 10
Critical Exception I can't ask for normalization

Exception

Message: AvroSerializer: unknown configuration property avro.serializer.normalize.schemas
Stack Trace:
at Confluent.SchemaRegistry.Serdes.AvroSerializer`1..ctor(ISchemaRegistryClient schemaRegistryClient, AvroSerializerConfig config)
at AvroSchemasSpecific.FunctionCalls.CallDataObject(CachedSchemaRegistryClient schemaRegistry, AvroSerializerConfig avroSerializerConfig) in C:\wrk\Repos\mockups\AvroSchemasSpecific\AvroSchemasSpecific\FunctionCalls.cs:line 107
at Program.

$(String[] args) in C:\wrk\Repos\mockups\AvroSchemasSpecific\AvroSchemasSpecific\Program.cs:line 134

Logs:

It's only a PoC before go to production, no logs yet

Checklist

Please provide the following information:

  • A complete (i.e. we can run it), minimal program demonstrating the problem. No need to supply a project file.
  • Confluent.Kafka nuget version.
  • Apache Kafka version.
  • Client configuration.
  • Operating system.
  • Provide logs (with "debug" : "..." as necessary in configuration).
  • Provide broker log excerpts.
  • Critical issue.
@ISBronny
Copy link
Contributor

+1

@ISBronny ISBronny linked a pull request Oct 18, 2023 that will close this issue
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging a pull request may close this issue.

2 participants