WEBVTT 00:04.690 --> 00:10.690 We have just successfully created the first topic in a class time, and the name of this topic is cities, 00:10.990 --> 00:15.700 and you could use Kafka topics as a script with the named option. 00:15.770 --> 00:19.070 This does list in order to list all topics available in the Gloster. 00:19.480 --> 00:23.880 And now it's a good time to start sending some messages to dystopic cities. 00:24.190 --> 00:26.810 And for that we could use any producer. 00:27.280 --> 00:34.140 There is a built in producer that the ships with Kafka installation and its name is Kafka Council producer. 00:34.330 --> 00:39.200 It is located in Benfold and here it is, Kafka cocounsel producer. 00:39.400 --> 00:40.720 Let's use the script. 00:41.020 --> 00:50.470 Let's clear terminal and type been Kafka, this console desk producer, Lotus Edge and let's try to 00:50.470 --> 00:51.520 execute it like soul. 00:52.610 --> 00:58.820 Of course, as usually we will get a list of options, it means that in order to start this console 00:58.820 --> 01:02.960 producer, we need to specify some required arguments. 01:03.140 --> 01:05.660 And first required argument is Storbeck. 01:05.810 --> 01:12.140 Here you see that it is required and a second one is located at the beginning of this list, and it 01:12.140 --> 01:14.290 is Breuker least this one. 01:14.630 --> 01:18.380 And basically in this list, we need to specify at least of the brokers. 01:18.530 --> 01:24.110 And if there are multiple brokers available, then you should split them using a like sole. 01:24.440 --> 01:31.570 OK, let's add that those arguments broker list and Dobek, let's clear Terminal and Type II. 01:31.580 --> 01:39.470 Beenz Legoff, this console desk producer S.H. Next comes list argument. 01:39.980 --> 01:44.510 And here will be connections between for our single broker it is localhost. 01:45.410 --> 01:53.360 Kolon, 1992, and next comes the second required argument, Dobek does that Storbeck and the here will 01:53.360 --> 01:56.450 be the name of the topic we want to produce matter. 01:56.450 --> 02:00.500 Just Storm and name of our first topic is cities like. 02:00.500 --> 02:03.620 So let's press enter and see what will happen. 02:05.100 --> 02:11.190 And we see this broad, and that means that this Kafka console producer has successfully connected to 02:11.190 --> 02:15.570 Kafka broker and now we are able to start sending some messages. 02:15.870 --> 02:18.600 Our topic that we have created is called Cities. 02:18.600 --> 02:22.400 And that's why let's send the names of some cities, for example. 02:22.410 --> 02:23.700 Let's start with New York. 02:24.700 --> 02:30.340 Press enter, the next one will be in Berlin, next one, let's say, will be Paris. 02:31.940 --> 02:32.660 One more. 02:33.800 --> 02:34.910 And one more thing. 02:36.050 --> 02:42.800 OK, we have just successfully sent several messages using Kafka console producer, but now there are 02:42.800 --> 02:43.850 several questions. 02:44.330 --> 02:50.630 First one, where those messages successfully received by coffeecake, last or not, second one where 02:50.630 --> 02:57.470 those messages were stored in Kafka, Gloster and last one, how we are able to consume those messages 02:57.470 --> 02:58.680 from Kafka, Kloster. 02:59.000 --> 03:02.120 And let me answer the last question first and the next. 03:02.120 --> 03:08.900 Let's launch built in Kafka Council consumer and try to consume those messages that we have just sent 03:08.900 --> 03:09.990 by producer. 03:10.280 --> 03:11.470 Let's try that next. 03:11.480 --> 03:11.950 Bye bye.