Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-5980 Add load tests for Core Apache Beam operations
  3. BEAM-6207

extend "Data insertion Pipeline" with Kafka IO

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • P4
    • Resolution: Resolved
    • None
    • 2.11.0
    • io-java-kafka, testing
    • None

    Description

      Since now we have the Data insertion pipeline based on PubSubIO, it can be easily extended with KafkaIO if needed. Same data then could be published to any of the sinks leaving out the choice and enabling the data insertion pipeline for Flink.

       

      Attachments

        Issue Links

          is a clone of

          Sub-task - The sub-task of the issue BEAM-6201 Provide a "Data insertion pipeline" for Python suites

          • P4 - Trivial items, spelling errors, etc.
          • Resolved
          links to

          Web Link GitHub Pull Request #7612

          Activity

            People

              mwalenia Michał Walenia
              ŁukaszG Lukasz Gajowy
              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 - 4h 40m
                  4h 40m