Skip to content

Kafka source uses deprecated config for the Schema Registry #716

@yruslan

Description

@yruslan

Describe the bug

In this part of code

kafkaAvroConfig.valueNamingStrategy
.applyNamingStrategyToAbrisConfig(abrisValueBase, topic, isKey = false)
.usingSchemaRegistry(schemaRegistryClientConfig)

the schemaRegistryClientConfig is passed as

schema.registry.basic.auth.user.info -> [censored],
schema.registry.basic.auth.credentials.source -> USER_INFO, 

but this is obsolete. It should pass it as

basic.auth.user.info -> [censored], 
basic.auth.credentials.source -> USER_INFO,

Code and/or configuration snippet that caused the issue

--

Expected behavior

Kafka source should pass the correct and up to date configuration to the Schema Registry.

Context

  • Pramen/pramen-py version: 1.13.6

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions