ink.apache.org>
Subject: Re: kinesis producer setCustomPartitioner use stream's own data
Hi Sathi,
The `getPartitionId` method is invoked with each record from the stream. In
there, you can extract values / fields from the record, and use that to
determine the target partition id.
Is this what you had
Hi Sathi,
The `getPartitionId` method is invoked with each record from the stream. In
there, you can extract values / fields from the record, and use that to
determine the target partition id.
Is this what you had in mind?
Cheers,
Gordon
On February 21, 2017 at 11:54:21 AM, Sathi Chowdhury
Hi flink users and experts,
In my flink processor I am trying to use Flink Kinesis connector . I read from
a kinesis stream , and After the transformation (for which I use
RichCoFlatMapFunction), json event needs to sink to a kinesis stream k1.
DataStream myStream = see.addSource(new
