+ cross+posting to user@beam.apache.org <mailto:user@beam.apache.org>
Under the hood, KinesisIO uses IKinesisProducer to write to Kinesis stream. I’m not very familiar with Firehose API, so I’m not sure that KPL supports writes directly to Firehose. In the same time, Kinesis Stream can be used as a source for Kinesis Firehose. So, I guess the chain could be like this: KinesisIO → Kinesis Stream → Kinesis Firehose > On 6 Jun 2020, at 20:03, Brahmachaitanya Wajapey > <brahmachaitanyawaja...@gmail.com> wrote: > > Hi, > > Apache beam supports KinesisIO connector. Is this only for Kinesis streams or > it can be used to put records in Kinesis firehose as well? > > I have a requirement where i read events from kafka and I have to put the > records in kinesis firehose. > > So, can we use KinesisIO connector for this? > > Thanks > Brahma
