Skip to content

Commit 9ca3669

Browse files
fix: clean up whitespace and improve consumer configuration check (resolve conflicts)
Signed-off-by: rideshnath-scout <[email protected]>
1 parent b1c1489 commit 9ca3669

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

bindings/aws/kinesis/kinesis.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -341,11 +341,11 @@ func (a *AWSKinesis) deregisterConsumer(_ context.Context, streamARN *string, co
341341
func (a *AWSKinesis) waitUntilConsumerExists(ctx context.Context, input *kinesis.DescribeStreamConsumerInput) error {
342342
ctx, cancel := context.WithTimeout(ctx, 3*time.Minute)
343343
defer cancel()
344-
344+
345345
bo := backoff.NewExponentialBackOff()
346346
bo.InitialInterval = 2 * time.Second
347347
bo.MaxInterval = 30 * time.Second
348-
348+
349349
return backoff.Retry(func() error {
350350
consumer, err := a.kinesisClient.DescribeStreamConsumer(ctx, input)
351351
if err != nil {
@@ -431,8 +431,7 @@ func (a *AWSKinesis) getStreamARN(ctx context.Context, streamName string) (*stri
431431
}
432432

433433
func (a *AWSKinesis) workerCfg(_ context.Context, stream, region, mode, applicationName string) *config.KinesisClientLibConfiguration {
434-
const sharedMode = "shared"
435-
if mode == sharedMode {
434+
if mode == SharedThroughput {
436435
return config.NewKinesisClientLibConfigWithCredential(applicationName, stream, region, "", a.v2Credentials)
437436
}
438437
return nil

0 commit comments

Comments
 (0)