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

Add support for dynamic destinations when writing to Kinesis

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Open
    • P3
    • Resolution: Unresolved
    • None
    • None
    • io-java-kinesis
    • None

    Description

      KinesisIO is only able to write to a single named stream.

      It would be great if we could dynamically write to different Kinesis streams.

       

      I believe this functionality is available in KafkaIO with writeRecords() where the topic name is defined in WriteRecord.

      https://the-asf.slack.com/archives/C9H0YNP3P/p1586966769192700

      Attachments

        Issue Links

          is related to

          Improvement - An improvement or enhancement to an existing feature or task. BEAM-6385 Add support for dynamic destinations when writing to Kafka

          • P3 - Non-urgent bugs, features, and improvements
          • Open

          Activity

            People

              Unassigned Unassigned
              Dan-Ladd Dan Ladd
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated: