Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-9329

Support request of schemas by version on KafkaIO + Confluent Schema Registry

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • P3
    • Resolution: Fixed
    • None
    • 2.20.0
    • io-java-kafka
    • None

    Description

      BEAM-7310 introduced support to get Avro Schemas from Confluent Schema Registry as part of KafkaIO. By default it always takes the latest (most recent) version of the Schema. It would be nice to allow users to also request specific versions of the Schema.

      Attachments

        Issue Links

          depends upon

          Improvement - An improvement or enhancement to an existing feature or task. BEAM-9364 Refactor KafkaIO to use DeserializerProviders

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Resolved
          links to

          Web Link GitHub Pull Request #10962

          Activity

            People

              iemejia Ismaël Mejía
              iemejia Ismaël Mejía
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 2h 50m
                  2h 50m