Skip to content

Commit fd0a5a9

Browse files
committed
Altera comportamento de limite excedido
Atualiza valor padrão para tratamento de fluxo altera lógica de ação ao exceder limites de mensagens para bloquear
1 parent e413860 commit fd0a5a9

File tree

1 file changed

+1
-1
lines changed
  • wrapper/publisher/driver/contrib/cloud.google.com/pubsub/v1

1 file changed

+1
-1
lines changed

wrapper/publisher/driver/contrib/cloud.google.com/pubsub/v1/config.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ func ConfigAdd(path string) {
4242
config.Add(path+bufferedByteLimit, 10*1e7, "the maximum number of bytes that can be pending in memory across all topics")
4343
config.Add(path+maxOutstandingMessages, 1000, "the maximum number of messages that can be pending in memory for publishing")
4444
config.Add(path+maxOutstandingBytes, -1, "the maximum total size of messages that can be pending in memory for publishing")
45-
config.Add(path+limitExceededBehavior, 0, "behavior when flow control limits are exceeded: Block or Ignore")
45+
config.Add(path+limitExceededBehavior, 1, "behavior when flow control limits are exceeded: Block or Ignore")
4646
config.Add(path+enableCompression, false, "whether to compress messages before sending")
4747
config.Add(path+compressionBytesThreshold, 240, "the minimum size a message must be to be compressed before sending")
4848
}

0 commit comments

Comments
 (0)