WEBVTT

00:04.290 --> 00:09.630
In the previous example, we have started multiple consumers in the same consumer group and we have

00:09.630 --> 00:15.540
verified that the participants were spread equally across different consumers in the same consumer group.

00:15.930 --> 00:17.880
And now short challenge for you.

00:21.590 --> 00:25.830
In the previous example, we have used the consumer without a middle class.

00:26.360 --> 00:33.860
Now you should use glass gold consumer with partitions assignment this one, please try to start multiple

00:33.860 --> 00:40.500
copies of this main method and see how messages will be received by different consumers in the same

00:40.940 --> 00:41.350
group.

00:42.170 --> 00:42.820
Please pause.

00:42.830 --> 00:49.490
We do now launch multiple consumers afterwards, start produce a produce some massages and the next.

00:49.490 --> 00:54.650
Observe how messages will be received by multiple consumers in this third group.

00:55.070 --> 01:00.560
And afterwards, please try to explain yourself why behavior is different from behavior.

01:00.560 --> 01:05.080
In previous example, when we have used consumer was all to commit glass.

01:05.420 --> 01:06.380
I wish you good luck.

01:09.620 --> 01:15.800
OK, are you going to do it myself, but I'll give you a short explanation in the previous example,

01:15.800 --> 01:18.740
we have used subscribe method of the consumer.

01:19.340 --> 01:23.780
In this glass, we use a sign method of the consumer.

01:24.140 --> 01:31.130
In such case, every consumer independent of the assignment to consumer group will receive all messages

01:31.250 --> 01:34.610
from partitions that were assigned to this consumer.

01:34.730 --> 01:40.610
Because actually you performed manual assignment of the partitions with subscribe method.

01:40.850 --> 01:46.520
You actually allow Coffeecake last or to perform assignment of partitions to different consumers in

01:46.520 --> 01:47.960
the same consumer group.

01:48.410 --> 01:51.590
This explanation for this challenge, and that's all for this section.

01:51.770 --> 01:53.140
I'll see it in the next one.

01:53.190 --> 01:53.710
Bye bye.