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

Remove compatibility testing related code from KafkaIO.Read after SDF implementation has fully replaced the legacy read

Details

    • Task
    • Status: Open
    • P4
    • Resolution: Unresolved
    • None
    • None
    • io-java-kafka
    • None

    Description

      There were properties/features in KafkaIO.Read that were only available in Legacy or SDF read. In order to avoid hiding the lack of support a solution was implemented in: https://github.com/apache/beam/pull/16909 Further details can be found in the PR description about it.

      When SDF support/compatibility reaches the expected levels, and the SDF read completely replaces the legacy read this system should be cleaned up as well.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              bnemeth Balázs Németh
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:

                Time Tracking

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