WEBVTT 00:04.280 --> 00:10.320 No, we will create the first topic, and for that we will use another script called Kafka Topix, not 00:10.340 --> 00:18.400 S.H. And should that Zookeeper and Kafka etc. are up and running and please open up new time, no window. 00:18.740 --> 00:26.060 I'll go to new window and the director's window to another desktop in order to be able to switch back 00:26.060 --> 00:30.140 to Zookeeper and Kafka and observe what will happen here. 00:30.560 --> 00:34.880 Here in your terminal, windowless city to Kafka, Fooldom Clear Terminal. 00:34.880 --> 00:38.330 And he'll also run script located in Benfold. 00:38.450 --> 00:42.890 And the name of the script is Kafka Desktop, not S.H.. 00:43.190 --> 00:45.980 And let's try to run this script without any arguments. 00:46.610 --> 00:47.090 Enter. 00:48.580 --> 00:55.540 And I see this output with a long list of different options, and that means that we are not able to 00:55.690 --> 01:01.620 run the script without any arguments like this, we need to use some options for that. 01:01.870 --> 01:08.110 And you see here at the top that this script is used for creation deletion and the changing of topics. 01:08.530 --> 01:16.900 And now our goal is to create false topic in our Kafka class to notice that this terminal window is 01:16.900 --> 01:19.850 completely separated from doors to windows. 01:20.140 --> 01:23.950 So here we have also keep running and here we are running in Kafka. 01:24.580 --> 01:28.960 And basically Zookeeper and Sarah have formed Kafka, Kloster. 01:29.170 --> 01:36.070 And now somehow from this script, we need to connect to that Kafka Gloster and create new topic down 01:36.730 --> 01:37.190 this way. 01:37.210 --> 01:39.850 Now we will use several named options. 01:40.090 --> 01:41.820 And first one is option. 01:41.830 --> 01:46.750 Does this create like so let's press enter now and see what will happen. 01:47.940 --> 01:54.750 And now we'll see exception in thread, the main java, the blank, and this exception says us that 01:54.870 --> 01:59.510 we need to specify our bootstrap Sarah or Zork cheaper. 01:59.910 --> 02:01.320 And that's what I have told you. 02:01.320 --> 02:07.200 In the previous larochelle, there was coffeecake last and zookeeper's running at this port by default. 02:07.200 --> 02:10.770 And Cafcass server single broker is running at this port. 02:11.160 --> 02:17.070 And in order to connect to this coffeecake last resort keeper and Cafcass Silva, we should specify 02:17.280 --> 02:20.430 either so-called bootstrap Sara. 02:20.700 --> 02:29.430 And it could be any of the Sarabeth into Gloster, or you could specify Zork and connect via Zookeeper 02:29.430 --> 02:31.430 IP Address and Port. 02:31.860 --> 02:34.860 Let's use the bootstrap server option for now. 02:35.070 --> 02:39.510 And after create option, we need to add another named option for that. 02:39.510 --> 02:43.710 Again, let's use two dashes and next type bootstrap. 02:44.650 --> 02:52.930 There, ceremony after space comes IP address and board of bootstrap server, and in our case, Celera 02:52.930 --> 03:00.930 is running at the local acost and bought 1992 this one, and you could type IIs or localhost all nine 03:00.940 --> 03:08.820 to 92 or specify IP address of localhost like 127 zero zero one. 03:09.130 --> 03:12.530 But let me type here localhost for simplicity. 03:13.300 --> 03:16.630 And next comes the board of a booster, etc.. 03:16.780 --> 03:18.750 This one, 1992. 03:19.420 --> 03:20.860 Let's enter it like soul. 03:21.040 --> 03:23.200 And now let's try to create a new topic. 03:23.440 --> 03:24.010 Antrel. 03:25.460 --> 03:33.050 And now I see again a list of health options, let me scroll up to the very beginning of this list and 03:33.050 --> 03:37.480 here I see another error missing required argument topic. 03:37.760 --> 03:44.190 And that means that in order to create a new topic, we need to specify its name by using another named 03:44.210 --> 03:45.870 argument called topic. 03:46.250 --> 03:46.880 Let's do that. 03:47.030 --> 03:50.030 Let me basically clear it up, go to history. 03:50.300 --> 03:58.850 And here at Annuls are named argument desk topic and outer space usually specify the name of the new 03:58.850 --> 03:59.240 topic. 03:59.600 --> 04:03.230 And let's create topic cold cities like Seoul. 04:03.650 --> 04:09.490 And this topic will be used for exchange of messages with names of different cities. 04:09.870 --> 04:11.030 Let's are now. 04:12.320 --> 04:18.270 And now there is no error, it's a good sign for sure, and no, we can try to go back to Kafka, Sarah, 04:18.440 --> 04:22.060 we know this one and observe what has happened here. 04:22.400 --> 04:28.610 And if you'll scroll a bit, you'll see such information in four different cities, zero broker or zero. 04:29.000 --> 04:33.890 And that means that new partition for new topic cities was created. 04:34.250 --> 04:38.510 Basically, let's go to resource to the court and observe logs here. 04:38.840 --> 04:42.020 Go to several log minified this section. 04:42.020 --> 04:48.770 And here you'll see such matters, such as creating topic cities with configuration and empty object. 04:49.040 --> 04:53.930 That means that the new topic cities was created with default configuration. 04:54.350 --> 05:01.490 And let's basically observe what has happened in coffeecake last year after creation of new topic after 05:01.490 --> 05:02.230 this comment. 05:02.420 --> 05:03.800 Let's do that next by.