File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -72,7 +72,9 @@ public function testShouldInjectItsSerializerToConsumer()
72
72
73
73
public function testShouldNotCreateConsumerTwice ()
74
74
{
75
- $ context = new RdKafkaContext ([]);
75
+ $ context = new RdKafkaContext (['global ' => [
76
+ 'group.id ' => uniqid ('' , true ),
77
+ ]]);
76
78
$ queue = $ context ->createQueue ('aQueue ' );
77
79
78
80
$ consumer = $ context ->createConsumer ($ queue );
@@ -83,9 +85,11 @@ public function testShouldNotCreateConsumerTwice()
83
85
84
86
public function testShouldCreateTwoConsumers ()
85
87
{
86
- $ context = new RdKafkaContext ([]);
88
+ $ context = new RdKafkaContext (['global ' => [
89
+ 'group.id ' => uniqid ('' , true ),
90
+ ]]);
87
91
$ queueA = $ context ->createQueue ('aQueue ' );
88
- $ queueB = $ context ->createQueue ('aQueue ' );
92
+ $ queueB = $ context ->createQueue ('bQueue ' );
89
93
90
94
$ consumer = $ context ->createConsumer ($ queueA );
91
95
$ consumer2 = $ context ->createConsumer ($ queueB );
You can’t perform that action at this time.
0 commit comments