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

Kafka backward compatibility

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • P2
    • Resolution: Won't Fix
    • 2.13.0
    • Not applicable
    • io-java-kafka
    • None

    Description

      getting below error using kafka 1.0 with Beam 2.13.0

      Uncaught throwable from user code: java.lang.IllegalStateException: No TransformEvaluator registered for BOUNDED transform Read(CreateSource)
      at org.apache.beam.vendor.guava.v20_0.com.google.common.base.Preconditions.checkState(Preconditions.java:518)

      So I had to downgrade beam version to 2.8.0 to work it.

      Attachments

        Activity

          People

            aromanenko Alexey Romanenko
            reenusaluja Reenu Saluja
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: