When using Flink Stateful Function's KinesisIngressBuilder, I do not see a way to set things like ConsumerConfigConstants.SHARD_GETRECORDS_MAX or ConsumerConfigConstants.SHARD_GETRECORDS_INTERVAL_MILLIS
Looking at KinesisSourceProvider, it appears that this is the spot that creates the FlinkKinesisConsumer. The function named propertiesFromSpec(kinesisIngressSpec) only allows for AWS properties and a few startup position properties. ConsumerConfigConstants.SHARD_GETRECORDS_MAX cannot be provided. Is there an obvious workaround?
