Kinesis conector and record aggregation

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Kinesis conector and record aggregation

Yoandy Rodríguez

Hello everyone,

I'm passing this property to my FlinkKinesisProducer (kinProp doesn't hold a value for AggregatioEnabled yet)

producerConfig.put("AggregationEnabled ", "false");

But records are still aggregated. I'm using Flink 1.6 with Amazon Kinesis Applications. Is there another way to disable record aggregation?

-- 
Best Regards
Yoandy Rodríguez