You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Yoandy Rodríguez <mr...@gmail.com> on 2019/09/05 14:47:54 UTC

Kinesis conector and record aggregation

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