Skip to content

Avro schema autoregistration #1075

@arkadius

Description

@arkadius

Would be nice to be able to:
As a user I know which message I want to publish as an avro , e.g.:

{ foo: #input.intValue, bar: #input.decimalValue

, but haven't created topic yet and haven't added schema to it.

So I want to:

  • use node avro-sink
  • pick topic that haven't exists yet
  • pick <new schema version> (because current empty schema mean <latest schema version>
  • provide key/value
  • run process

It should cause: new schema is added.

Confluent client support https://docs.confluent.io/current/schema-registry/schema_registry_tutorial.html#auto-schema-registration
(it is turned on be default so we also using it)
We should consider: how changes in existing parameters will break compatibility of current node

Metadata

Metadata

Assignees

No one assigned

    Labels

    enhancementnot on roadmapNussknacker development team does not plan to work on that in foreseeable future

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions