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

Add support to write to multiple topics with KafkaIO

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • None
    • 2.10.0
    • io-java-kafka

    Description

      Add support for writing to Kafka based upon contents of the data. This is similar to the dynamic destination approach for file IO and other sinks.

       

      Source of request: https://lists.apache.org/thread.html/a89d1d32ecdb50c42271e805cc01a651ee3623b4df97c39baf4f2053@%3Cuser.beam.apache.org%3E

      Attachments

        Issue Links

          depends upon

          Improvement - An improvement or enhancement to an existing feature or task. BEAM-6063 KafkaIO: add writing support with ProducerRecord

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Resolved
          links to

          Web Link GitHub Pull Request #6776

          Web Link GitHub Pull Request #7371

          Activity

            People

              aromanenko Alexey Romanenko
              lcwik Luke Cwik
              Votes:
              1 Vote for this issue
              Watchers:
              4 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 - 5h 40m
                  5h 40m