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

Refactor KafkaIO to use DeserializerProviders

Details

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

    Description

      BEAM-7310 introduced support for Confluent Schema Registry, even if the API did not explicitly mention DeserializerProviders it opened the option to use multiple providers of Deserializers. The goal of this ticket is to refactor the KafkaIO API to reflect this new concept both for local Deserializer resolution and Confluent Schema Registry based (notice that this one becomes better isolated).

      Attachments

        Issue Links

          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 - 3.5h
                  3.5h