WEBVTT

00:04.480 --> 00:11.020
Now you have understanding how messages were spread in our case across different partitions, we have

00:11.020 --> 00:17.020
produced only three messages and they were spread equally across all three partitions.

00:17.350 --> 00:25.280
And in such case, consumer may read messages not in the same order as they were produced by a producer.

00:25.480 --> 00:27.220
That is very, very important.

00:27.730 --> 00:29.040
Now, let's try to the following.

00:29.320 --> 00:33.670
Let's try to read Martha just by consumer from specific partition.

00:33.680 --> 00:35.340
Let's say partition one.

00:35.800 --> 00:36.370
Let's do that.

00:36.670 --> 00:38.550
We need to adjust to this comment.

00:38.560 --> 00:44.190
Let me go here and let me copy this entire section and pasted below.

00:44.710 --> 00:49.300
And now I want to read Martha just from beginning from specific.

00:50.420 --> 00:51.080
Patison.

00:52.480 --> 00:59.020
And all what we need to adjust here in this comment is to add the option partition, Expensify number

00:59.020 --> 01:01.710
of partition we want to read messages from.

01:02.050 --> 01:03.880
So let me add this option here.

01:04.090 --> 01:05.410
There's this partition.

01:06.470 --> 01:12.570
And let's read messages from number one, and don't forget to add backslash here, OK?

01:12.860 --> 01:13.660
We are all set.

01:13.700 --> 01:20.600
Let me copy you this comment and now go back to Tamino, go to council consumer and show that you are

01:20.600 --> 01:21.340
in this step.

01:21.560 --> 01:26.900
Let's stop this council consumer and let's run a new one here in the same thep.

01:27.110 --> 01:30.680
Let's clear Tamino and let's based command that we have just crafted.

01:30.980 --> 01:32.030
Let's press enter.

01:33.800 --> 01:40.880
And now I'll see only a single message, and in my case, it is dark and we have export the message

01:40.880 --> 01:47.060
dog was brought in protection animals one here with this, let me go to Animals one.

01:47.080 --> 01:48.710
So here it is again.

01:48.710 --> 01:54.500
In your case, you may see a completely different message because again, in your case, messages may

01:54.500 --> 01:56.660
be spread in another fashion.

01:57.080 --> 02:04.370
OK, in the same way you can read from another petition and let me adjust this comment and try to read

02:04.370 --> 02:06.090
from position number two.

02:06.410 --> 02:08.600
So let me quote again this comment.

02:09.140 --> 02:14.830
Terminate this command terminal based command and now I should seek out.

02:14.840 --> 02:15.820
Yes, here it is.

02:16.280 --> 02:16.700
Great.

02:16.910 --> 02:21.380
That's how you are able to read messages from specific partition.

02:22.040 --> 02:28.580
Let's next to try to produce one more message, observe where this message will be stored.

02:28.790 --> 02:35.900
And afterwards, let's try to read the messages by the consumer using specific starting of set.

02:36.260 --> 02:42.260
And first we will try to read from Offset Zero and afterwards we will try to read from offset number

02:42.260 --> 02:42.560
one.

02:42.680 --> 02:43.570
So see you next.

02:43.580 --> 02:44.050
Bye bye.