Skip to content

Commit c92a671

Browse files
committed
Consumer group interactive test is repaired
1 parent fe75f27 commit c92a671

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

test/interactive/consumer_group/write_messages_periodically.rb

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -10,13 +10,8 @@
1010
category = ENV['CATEGORY'] || 'testPostgresConsumerGroup'
1111
logger.info "Category: #{category}"
1212

13-
stream_names = [
14-
Controls::StreamName.example(category: category),
15-
Controls::StreamName.example(category: SecureRandom.hex)
16-
]
17-
1813
loop do
19-
stream_name = stream_names.sample
14+
stream_name = Controls::StreamName.example(category: category)
2015

2116
message = Controls::Message.example
2217

0 commit comments

Comments
 (0)