WEBVTT 00:04.260 --> 00:10.320 We have just looked at contents of the log folders for every broker, and we have ensured that the partitions 00:10.320 --> 00:16.820 were spread equally across all brokers, no less loanshark, coproducer, and produce something just 00:16.830 --> 00:17.970 to stop it. 00:18.390 --> 00:22.110 Let me close this up and the gold door file with commands. 00:22.410 --> 00:28.860 Scroll down and let's select this comment before let's adjust to topic name locales like Seoul. 00:29.040 --> 00:33.200 And he adjusted as well because we will launch consumer as well. 00:33.450 --> 00:36.090 So let's compare this command gold to terminal. 00:36.090 --> 00:38.460 Open up a new tab city to COFCO. 00:39.670 --> 00:47.040 And Loung producer actually is not fully correct, we should specify an entire list of all brokers availability 00:47.050 --> 00:53.220 to Gloster for redundancy again, but if there was only a single server, you will be able indeed connect 00:53.220 --> 00:59.110 to the entire cluster and produce messages to all available brokers to make it fully correct. 00:59.140 --> 01:06.510 Let me quickly adjust this comment and add another centavos here like we did here in this comment. 01:06.760 --> 01:13.700 So let me quote this section based here like so and based here for consumer as well. 01:14.080 --> 01:14.500 Great. 01:14.740 --> 01:22.090 Let me copy this comment to once again go here, terminate this one clear terminal based on this command 01:22.300 --> 01:22.830 center. 01:23.390 --> 01:24.540 And now we are good to go. 01:24.730 --> 01:26.710 So let's produce several messages. 01:27.040 --> 01:28.530 First one will be Tesla. 01:28.990 --> 01:30.850 Next one will be BMW. 01:31.360 --> 01:33.330 Next one will be, let's say, Honda. 01:33.820 --> 01:38.680 And next one will be, for example, Audi sold for messages were produced. 01:38.680 --> 01:42.520 And now let's start the console, consumer and the consumer. 01:42.550 --> 01:48.340 Those messages will go to file with commands and the copy of this command request that I have already 01:48.350 --> 01:50.680 renamed the test topic two cars here. 01:50.680 --> 01:55.040 And here was entire list of all Sarus available in the Kloster. 01:55.270 --> 01:58.180 So let me copy this command and open up. 01:58.180 --> 02:01.000 A new terminal window was usually talk Kafka. 02:01.960 --> 02:03.730 Clear abdominal based command. 02:04.730 --> 02:10.040 And actually, I will see empty output because I haven't that the distance from beginning option and 02:10.040 --> 02:13.180 now this consumer will simply wait for new messages. 02:13.640 --> 02:14.720 Let's actually do that. 02:14.720 --> 02:16.940 Let's produce one more message here. 02:17.150 --> 02:19.790 And it will be, let's say, Mazher item. 02:21.490 --> 02:28.660 And now the consumer should receive this message and hear what is wonderful, now we have consumer running 02:28.660 --> 02:34.170 and the producer also running as well, and we have produced some messages to our current topic. 02:34.510 --> 02:41.170 Also, you may see that this consumer was connected to an entire topic, and that means that it will 02:41.170 --> 02:43.960 read all messages from all politicians. 02:44.320 --> 02:50.560 And currently there are five partitions and we have explored that all of them were spread across different 02:50.560 --> 02:51.160 brokers. 02:51.700 --> 02:52.120 Great. 02:52.360 --> 02:59.500 And don't ask for you, please open up Dimpy folder and locate the all folders with logs and try to 02:59.500 --> 03:07.120 find the which partitions were used for writing of those messages and how those messages were spread 03:07.120 --> 03:08.680 across different partitions. 03:09.010 --> 03:14.550 I will do it myself now, but I hope that you'll be able to figure it out yourself successfully. 03:14.680 --> 03:15.790 So I wish you good luck. 03:16.660 --> 03:18.160 OK, now let's proceed. 03:18.160 --> 03:20.320 And the next list, the following. 03:20.590 --> 03:27.310 Let's explore the details of this topic, topic cards and let's see the details about partitions and 03:27.310 --> 03:31.170 observe how leaders were elected for a repartition. 03:31.510 --> 03:33.040 Let's do that next by my.