Skip to content

Commit f31ae00

Browse files
committed
Update max_ack_pending validation to include -1 (unlimited)
1 parent 8bcec88 commit f31ae00

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

jetstream/resource_jetstream_consumer.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -188,7 +188,7 @@ func resourceConsumer() *schema.Resource {
188188
Description: "Maximum pending Acks before consumers are paused",
189189
Optional: true,
190190
Default: 20000,
191-
ValidateFunc: validation.IntAtLeast(0),
191+
ValidateFunc: validation.IntAtLeast(-1),
192192
ForceNew: false,
193193
},
194194
"heartbeat": {

jetstream/resource_jetstream_consumer_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ resource "jetstream_consumer" "TEST_C2" {
6464
stream_id = jetstream_stream.test.id
6565
durable_name = "C2"
6666
stream_sequence = 10
67-
max_ack_pending = 20
67+
max_ack_pending = -1
6868
filter_subjects = ["TEST.a", "TEST.b"]
6969
max_waiting = 10
7070
max_batch = 1
@@ -344,7 +344,7 @@ func TestResourceConsumer(t *testing.T) {
344344
testConsumerExist(t, mgr, "TEST", "C2"),
345345
testConsumerHasFilterSubjects(t, mgr, "TEST", "C2", []string{"TEST.a", "TEST.b"}),
346346
resource.TestCheckResourceAttr("jetstream_consumer.TEST_C2", "stream_sequence", "10"),
347-
resource.TestCheckResourceAttr("jetstream_consumer.TEST_C2", "max_ack_pending", "20"),
347+
resource.TestCheckResourceAttr("jetstream_consumer.TEST_C2", "max_ack_pending", "-1"),
348348
resource.TestCheckResourceAttr("jetstream_consumer.TEST_C2", "inactive_threshold", "0"),
349349
),
350350
},

0 commit comments

Comments
 (0)