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

Deprecate older kafka clients and make kafka clients a provided dependency

Details

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

    Description

      Kafka versions 0.10.1 and above have better support for timestamps. We intend to deprecate older versions as a first step towards dropping the support entirely.

      The older versions (0.9.x and 0.10.0) at run time still work, but KafkaIO itself does not support these at build time. It lets us remove some of the reflection based code used to support older versions at build time. 

      Attachments

        Activity

          People

            rangadi Raghu Angadi
            rangadi Raghu Angadi
            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