diff --git a/pkg/source/kinesis/kinesis_source.go b/pkg/source/kinesis/kinesis_source.go index d9ad9fb2..8282d52d 100644 --- a/pkg/source/kinesis/kinesis_source.go +++ b/pkg/source/kinesis/kinesis_source.go @@ -124,7 +124,7 @@ func (f adapter) ProvideDefault() (interface{}, error) { ReadThrottleDelayMs: 250, // Kinsumer default is 250ms ConcurrentWrites: 50, ShardCheckFreqSeconds: 10, - LeaderActionFreqSeconds: 300, + LeaderActionFreqSeconds: 60, } return cfg, nil