Increase drop consumer timeout

Signed-off-by: sashayakovtseva <[email protected]>
sashayakovtseva · Mar 5, 2024 · c9ad489 · c9ad489
1 parent 34ab658
commit c9ad489
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/datastore/ydb/watch.go b/internal/datastore/ydb/watch.go
@@ -196,7 +196,7 @@ func (y *ydbDatastore) watch(
 			return
 		}
 		defer func(topic string) {
-			ctx, cancel := context.WithTimeout(context.Background(), time.Millisecond*500)
+			ctx, cancel := context.WithTimeout(context.Background(), time.Second*3)
 			defer cancel()
 
 			err := y.driver.Topic().Alter(ctx, topic, topicoptions.AlterWithDropConsumers(consumerUUID))