در این مطلب، ویدئو قسمت 7 – تولید کننده کافکا در پایتون | کافکا برای مبتدیان با زیرنویس فارسی را برای دانلود قرار داده ام. شما میتوانید با پرداخت 15 هزار تومان ، این ویدیو به علاوه تمامی فیلم های سایت را دانلود کنید.اکثر فیلم های سایت به زبان انگلیسی می باشند. این ویدئو دارای زیرنویس فارسی ترجمه شده توسط هوش مصنوعی می باشد که میتوانید نمونه ای از آن را در قسمت پایانی این مطلب مشاهده کنید.
مدت زمان فیلم: 00:20:33
تصاویر این ویدئو:
قسمتی از زیرنویس این فیلم:
00:00:01,980 –> 00:00:06,910
2
00:00:17,279 –> 00:00:19,720
3
00:00:19,720 –> 00:00:21,970
4
00:00:21,970 –> 00:00:24,039
5
00:00:24,039 –> 00:00:26,320
6
00:00:26,320 –> 00:00:28,660
7
00:00:28,660 –> 00:00:30,759
8
00:00:30,759 –> 00:00:32,380
9
00:00:32,380 –> 00:00:34,930
10
00:00:34,930 –> 00:00:36,460
11
00:00:36,460 –> 00:00:38,340
12
00:00:38,340 –> 00:00:41,230
13
00:00:41,230 –> 00:00:43,800
14
00:00:43,800 –> 00:00:46,360
15
00:00:46,360 –> 00:00:48,129
16
00:00:48,129 –> 00:00:49,510
17
00:00:49,510 –> 00:00:51,640
18
00:00:51,640 –> 00:00:54,399
19
00:00:54,399 –> 00:00:57,010
20
00:00:57,010 –> 00:00:59,620
21
00:00:59,620 –> 00:01:01,600
22
00:01:01,600 –> 00:01:03,879
23
00:01:03,879 –> 00:01:06,250
24
00:01:06,250 –> 00:01:08,980
25
00:01:08,980 –> 00:01:10,030
26
00:01:10,030 –> 00:01:12,520
27
00:01:12,520 –> 00:01:14,320
28
00:01:14,320 –> 00:01:16,960
29
00:01:16,960 –> 00:01:19,420
30
00:01:19,420 –> 00:01:21,430
31
00:01:21,430 –> 00:01:23,350
32
00:01:23,350 –> 00:01:25,360
33
00:01:25,360 –> 00:01:27,640
34
00:01:27,640 –> 00:01:30,400
35
00:01:30,400 –> 00:01:33,940
36
00:01:33,940 –> 00:01:36,310
37
00:01:36,310 –> 00:01:37,810
38
00:01:37,810 –> 00:01:40,240
39
00:01:40,240 –> 00:01:41,590
40
00:01:41,590 –> 00:01:44,470
41
00:01:44,470 –> 00:01:46,480
42
00:01:46,480 –> 00:01:48,190
43
00:01:48,190 –> 00:01:50,260
44
00:01:50,260 –> 00:01:53,050
45
00:01:53,050 –> 00:01:55,450
46
00:01:55,450 –> 00:01:58,060
47
00:01:58,060 –> 00:02:00,190
48
00:02:00,190 –> 00:02:02,860
49
00:02:02,860 –> 00:02:06,010
50
00:02:06,010 –> 00:02:07,900
51
00:02:07,900 –> 00:02:11,290
52
00:02:11,290 –> 00:02:14,260
53
00:02:14,260 –> 00:02:15,069
54
00:02:15,069 –> 00:02:17,319
55
00:02:17,319 –> 00:02:19,180
56
00:02:19,180 –> 00:02:20,799
57
00:02:20,799 –> 00:02:23,260
58
00:02:23,260 –> 00:02:24,879
59
00:02:24,879 –> 00:02:26,349
60
00:02:26,349 –> 00:02:28,389
61
00:02:28,389 –> 00:02:29,889
62
00:02:29,889 –> 00:02:32,079
63
00:02:32,079 –> 00:02:34,659
64
00:02:34,659 –> 00:02:37,359
65
00:02:37,359 –> 00:02:39,719
66
00:02:39,719 –> 00:02:42,189
67
00:02:42,189 –> 00:02:43,689
68
00:02:43,689 –> 00:02:45,790
69
00:02:45,790 –> 00:02:48,340
70
00:02:48,340 –> 00:02:50,500
71
00:02:50,500 –> 00:02:52,900
72
00:02:52,900 –> 00:02:54,939
73
00:02:54,939 –> 00:02:57,189
74
00:02:57,189 –> 00:02:59,829
75
00:02:59,829 –> 00:03:01,629
76
00:03:01,629 –> 00:03:03,819
77
00:03:03,819 –> 00:03:05,290
78
00:03:05,290 –> 00:03:07,810
79
00:03:07,810 –> 00:03:10,750
80
00:03:10,750 –> 00:03:13,480
81
00:03:13,480 –> 00:03:16,120
82
00:03:16,120 –> 00:03:18,310
83
00:03:18,310 –> 00:03:20,500
84
00:03:20,500 –> 00:03:22,870
85
00:03:22,870 –> 00:03:24,909
86
00:03:24,909 –> 00:03:26,949
87
00:03:26,949 –> 00:03:28,900
88
00:03:28,900 –> 00:03:31,030
89
00:03:31,030 –> 00:03:32,739
90
00:03:32,739 –> 00:03:34,720
91
00:03:34,720 –> 00:03:36,579
92
00:03:36,579 –> 00:03:38,709
93
00:03:38,709 –> 00:03:41,169
94
00:03:41,169 –> 00:03:43,180
95
00:03:43,180 –> 00:03:45,220
96
00:03:45,220 –> 00:03:47,650
97
00:03:47,650 –> 00:03:50,229
98
00:03:50,229 –> 00:03:52,299
99
00:03:52,299 –> 00:03:55,030
100
00:03:55,030 –> 00:03:58,359
101
00:03:58,359 –> 00:04:00,579
102
00:04:00,579 –> 00:04:02,799
103
00:04:02,799 –> 00:04:04,239
104
00:04:04,239 –> 00:04:06,609
105
00:04:06,609 –> 00:04:08,889
106
00:04:08,889 –> 00:04:11,439
107
00:04:11,439 –> 00:04:13,150
108
00:04:13,150 –> 00:04:14,919
109
00:04:14,919 –> 00:04:15,489
110
00:04:15,489 –> 00:04:17,769
111
00:04:17,769 –> 00:04:20,079
112
00:04:20,079 –> 00:04:22,840
113
00:04:22,840 –> 00:04:24,880
114
00:04:24,880 –> 00:04:27,250
115
00:04:27,250 –> 00:04:27,980
116
00:04:27,980 –> 00:04:29,810
117
00:04:29,810 –> 00:04:32,330
118
00:04:32,330 –> 00:04:35,540
119
00:04:35,540 –> 00:04:37,640
120
00:04:37,640 –> 00:04:39,860
121
00:04:39,860 –> 00:04:41,870
122
00:04:41,870 –> 00:04:43,820
123
00:04:43,820 –> 00:04:45,980
124
00:04:45,980 –> 00:04:48,590
125
00:04:48,590 –> 00:04:50,840
126
00:04:50,840 –> 00:04:52,730
127
00:04:52,730 –> 00:04:55,040
128
00:04:55,040 –> 00:04:59,120
129
00:04:59,120 –> 00:05:01,550
130
00:05:01,550 –> 00:05:03,470
131
00:05:03,470 –> 00:05:06,590
132
00:05:06,590 –> 00:05:08,960
133
00:05:08,960 –> 00:05:10,790
134
00:05:10,790 –> 00:05:12,560
135
00:05:12,560 –> 00:05:15,050
136
00:05:15,050 –> 00:05:17,270
137
00:05:17,270 –> 00:05:19,130
138
00:05:19,130 –> 00:05:22,280
139
00:05:22,280 –> 00:05:25,640
140
00:05:25,640 –> 00:05:27,680
141
00:05:27,680 –> 00:05:30,170
142
00:05:30,170 –> 00:05:32,030
143
00:05:32,030 –> 00:05:34,940
144
00:05:34,940 –> 00:05:37,370
145
00:05:37,370 –> 00:05:40,040
146
00:05:40,040 –> 00:05:41,930
147
00:05:41,930 –> 00:05:43,100
148
00:05:43,100 –> 00:05:45,380
149
00:05:45,380 –> 00:05:47,900
150
00:05:47,900 –> 00:05:50,240
151
00:05:50,240 –> 00:05:52,100
152
00:05:52,100 –> 00:05:54,200
153
00:05:54,200 –> 00:05:57,020
154
00:05:57,020 –> 00:05:59,090
155
00:05:59,090 –> 00:06:00,950
156
00:06:00,950 –> 00:06:02,930
157
00:06:02,930 –> 00:06:04,820
158
00:06:04,820 –> 00:06:07,160
159
00:06:07,160 –> 00:06:09,590
160
00:06:09,590 –> 00:06:11,690
161
00:06:11,690 –> 00:06:14,630
162
00:06:14,630 –> 00:06:17,480
163
00:06:17,480 –> 00:06:19,340
164
00:06:19,340 –> 00:06:21,800
165
00:06:21,800 –> 00:06:23,720
166
00:06:23,720 –> 00:06:26,510
167
00:06:26,510 –> 00:06:28,250
168
00:06:28,250 –> 00:06:30,350
169
00:06:30,350 –> 00:06:32,120
170
00:06:32,120 –> 00:06:34,100
171
00:06:34,100 –> 00:06:35,570
172
00:06:35,570 –> 00:06:36,430
173
00:06:36,430 –> 00:06:38,290
174
00:06:38,290 –> 00:06:40,930
175
00:06:40,930 –> 00:06:44,950
176
00:06:44,950 –> 00:06:46,810
177
00:06:46,810 –> 00:06:50,980
178
00:06:50,980 –> 00:06:54,130
179
00:06:54,130 –> 00:06:56,920
180
00:06:56,920 –> 00:07:00,730
181
00:07:00,730 –> 00:07:02,410
182
00:07:02,410 –> 00:07:07,660
183
00:07:07,660 –> 00:07:10,720
184
00:07:10,720 –> 00:07:13,120
[موسیقی] سلام مردم این جن است و ما به مجموعه خود در مورد کافکا برای مبتدیان ادامه می دهیم و در این ویدیو با نوشتن یک تهیه کننده کافکا در پایتون آشنا می شویم بنابراین از پایتون به عنوان زبان برنامه نویسی خود برای درک کل سرفه سرفه استفاده خواهیم کرد. برای سریال های مبتدی، بنابراین تولید کننده سرفه نقش مهمی در اکوسیستم بادبادک سرفه ایفا می کند و متوجه می شود که تولیدکنندگان پیام هایی را برای موضوعات مورد نظر خود منتشر می کنند، بنابراین ما می دانیم که تهیه کننده پیام هایی را برای موضوع منتشر می کند تا بتوانند موضوع مورد نظر خود را انتخاب کنند. به این معنی که آنها می توانند به یک موضوع خاص متصل شوند و سپس می توانند پیام را در واقعیت ارسال کنند، پیام ها به پارتیشن موضوع منتشر می شوند، بنابراین اگر مشاهده کردید که در زیر سرپوش چیزی که در حال رخ دادن است، تولید کننده یا ناشر پیام را به یک پارتیشن موضوعی ارسال می کند. فرض کنید این یک موضوع است و شامل سه پارتیشن p0 p1 و p2 است، بنابراین با این کادر آبی من یک موضوع را تعیین کرده ام و این موضوع شامل می شود ns سه پارتیشن p0 p1 و p2 وجود دارد و یک ناشر وجود دارد، بنابراین کاری که این ناشر انجام می دهد می تواند پیام ها را به همه پارتیشن ها ارسال کند، بنابراین اساساً اولین بار که به p0 ارسال می شود چه اتفاقی می افتد و سپس می تواند به p1 و سپس p2 ارسال کند و سپس به صورت تصادفی میتواند آن را به هر پارتیشنی که میخواهد بفرستد، وقتی این ساختار را میبینید، میتوانید ببینید که یک ناشر وجود دارد و یک سرور کافکا وجود دارد که این موضوع در آن پیکربندی برای تولیدکننده کافکا لازم است. به طوری که می تواند پیام را ارسال کند، بنابراین اولین چیز سرور بوت استرپ است، بنابراین فرض کنید در حال نوشتن یک ناشر یا تولید کننده هستید، سپس باید در مورد آدرس سرور کافکا بدانید تا به عنوان سرور بوت استرپ نامیده می شود، بنابراین اساساً شما می دهید. یک آدرس سرور بوت استرپ که اساساً آدرس IP و یک پورت است و پورت پیش فرض برای سرور بوت استرپ 9 0 9 2 است، بنابراین ناشر تنها زمانی می تواند به این موضوع متصل شود که آدرس توقف سرور را بداند. بعد از اینکه چه اتفاقی خواهد افتاد، باید به موضوع خاصی متصل شود که در اینجا دیدیم که تولید کننده پیام را به موضوع مورد نظر خود منتشر می کند، بنابراین پیکربندی مورد نیاز این ناشر همان چیزی است که به نام موضوع نیاز دارد که در آن می خواهد منتشر کند. پس از آن به چیزی نیاز دارد که به نام سریالساز ارزش s نامیده میشود، بنابراین هر زمان که دادهها را از طریق سیم ارسال میکنید، باید آن را سریالی کنید، به این معنی که باید همانطور که تبدیل شده است یا باید یک رشته ساده باشد تا بتوان آن را از طریق سیم ارسال کرد. هنگامی که شما پیامی به این موضوع خاص ارسال می کنید نباید یک شیء باشد، سپس آن مقادیر باید سریال شوند و به همین دلیل است که شما باید یک مقدار واقعی تعریف کنید که اساساً روشی است که مقدار سریال را برمی گرداند، بنابراین ما همه اینها را خواهیم دید. زمانی که ما تهیه کننده خود را می نویسیم، بنابراین در این ویدیو از این کتابخانه کافکا پایتون برای ایجاد یک تولید کننده یا ناشر استفاده می کنیم که می تواند به موضوع کافکا متصل شود و سپس از آن استفاده خواهیم کرد. g روش ارسال در آن تولیدکننده برای انتشار دادهها، بنابراین هنگامی که یک تولیدکننده کافکا ایجاد کردیم، سپس روش ارسال را روی آن فراخوانی میکنیم، همچنین از ماژول دیگری استفاده میکنیم که به آن Faker گفته میشود که به این معنی است که ما میتوانیم دادهها را جعل کنیم. شما می توانید یک داده جعلی تصادفی ایجاد کنید که در هنگام انتشار پیام مفید خواهد بود تا بتوانید تشخیص دهید که پیام های مختلفی در حال انتشار هستند، بنابراین آنچه که ما انجام خواهیم داد، سعی خواهیم کرد سناریویی ایجاد کنیم که کاربران در آن ثبت نام کنند. و اینکه دادههای ثبتنام مانند سن نام وجود دارد و چیزی نشان میدهد که این چیزها میتواند در آنجا وجود داشته باشد، اولین مورد این است که نمونهای از کارگزار واحد و یک پارتیشن را در نظر میگیریم، بنابراین ما یک خوشه کافیر را میگیریم که فقط یک کارگزار در آن حضور دارد. و در داخل تاپیک فقط یک پارتیشن وجود دارد، بنابراین در این سناریو چه اتفاقی میافتد، همه پیامها در یک پارتیشن منتشر میشوند، بگذارید بگوییم این یک موضوع است و فقط شامل پارتیشن e در آن صورت، ناشران کاری را انجام می دهند که فرض کنید ناشر صد پیام را منتشر می کند، بنابراین تمام صد پیام به این پارتیشن می رود زیرا تنها یک پارتیشن وجود دارد که این مورد را به عهده می گیرد و آن این است که یک کارگزار واحد وجود دارد و یکی وجود دارد. در این صورت تمام پیام هایی که در یک پارتیشن منتشر می شوند را پارتیشن کنید، بیایید اولین برنامه کافکا خود را ایجاد کنیم، بنابراین ترمینال خود را اینجا باز می کنم و یک پوشه برای پروژه خود ایجاد می کنم، بنابراین در داخل دایرکتوری یک پوشه فضای کاری وجود دارد و در اینجا یک پوشه پایتون وجود دارد، بنابراین به طور کلی من تمام پروژه های خود را در اینجا ایجاد می کنم، بنابراین اگر LS انجام دهم و بنابراین از قبل این پوشه وجود دارد، فقط سعی می کنم این پوشه کافکا را حذف کنم، بنابراین فرض کنید اکنون هیچ پوشه محافظت شده کافکا وجود ندارد. من قصد دارم یک پوشه جدید ایجاد کنم که به نام نسخه ی نمایشی برنامه کافکا یا نسخه ی نمایشی برای گرفتن سرفه نامیده می شود، بنابراین خوب است، بنابراین اکنون به داخل این کافکا اپتیمو می روم و می توانید ببینید که خالی است، از IntelliJ IDEA برای انجام کدنویسی برای شما استفاده خواهم کرد. می توانید از هر شناسه ای استفاده کنید انتخاب خود شما، تنظیمات اولیه متفاوت خواهد بود، اما پس از آن همه چیز مشترک خواهد بود، یعنی موارد کدگذاری، بنابراین من به داخل این درایو D می روم و فضای کاری وجود دارد و این نسخه نمایشی برنامه کافکا وجود دارد، بنابراین آن را انتخاب می کنم و من. هنگامی که یک پروژه مرتبط با Python را در IntelliJ IDEA باز کنید، آن را باز می کنم، سپس کاری که باید انجام دهید باید SDK را تعریف کنید، بنابراین من به داخل فایل و سپس ساختار پروژه و سپس این SDK می روم، بنابراین در اینجا کاری که من انجام خواهم داد، یک تعریف می کنم. SDK جدید و من به این SDK Python اضافه میکنم، بنابراین از محیط مجازی برای ایجاد پروژه خود استفاده خواهم کرد، بنابراین ایجاد محیط مجازی میتواند بر اساس شناسه شما بر اساس چیزی که استفاده میکنید متفاوت باشد، بنابراین میتوانید از این بخش صرفنظر کنید. از IntelliJ IDEA استفاده نمی کنید، بنابراین باید یک لحظه مجازی در پوشه Kafka Optima خود ایجاد کنید و سپس باید این کار را انجام دهید، بنابراین هنگامی که این محیط مجازی ایجاد شد، باید این محیط مجازی را در داخل پروژه خود، SDK محیط مجازی را انتخاب کنید. در اینجا نسخه ی نمایشی برنامه کافکا با موفقیت ایجاد شد، سپس به پروژه می روم و آن SDK را در اینجا انتخاب می کنم تا نسخه ی نمایشی برنامه کافکا باشد، اعمال می کنم و سپس ok می کنم، بنابراین این sdk قبلاً در اینجا ایجاد شده است و اگر اکنون محیط مجازی را ببینید پوشه ایجاد شده است راه اندازی اولیه برای توسعه پایتون ما قبلا انجام شده است، بنابراین من این تنظیمات را دوباره و دوباره در ویدیوی بعدی ایجاد نخواهم کرد، بنابراین این راه اندازی یک بار در این ویدیو خاص در ویدیوهای بعدی است که معمول است، یعنی مجازی محیط آنجا وجود خواهد داشت و پس از آن باید کتابخانه ها و موارد دیگر را نصب کنید، بنابراین همانطور که در اسلایدهای قبلی خود گفته ایم پس از انجام این کار، از آنچه از Kafka Python و کتابخانه های شکل پایتون استفاده خواهیم کرد برای ایجاد خود استفاده خواهیم کرد. پروژه اکنون کاری که من اینجا انجام می دهم این است که من یک کتابخانه ایجاد خواهم کرد، آن کتابخانه ها را نصب خواهم کرد، بنابراین ترمینال خود را باز می کنم و می گویم یک pip install cough Python بنابراین آن را نصب خواهم کرد، بنابراین می گویم pip install ک afka Python و کاری که این کار را انجام می دهد
185
00:07:13,120 –> 00:07:16,510
، سعی می کند کافکا پایتون را از
186
00:07:16,510 –> 00:07:18,880
مخزن کاغذی واکشی کند و آن را
187
00:07:18,880 –> 00:07:20,530
در داخل این پوشه محیط مجازی نصب می کند،
188
00:07:20,530 –> 00:07:23,200
بنابراین همانطور که می بینید با
189
00:07:23,200 –> 00:07:25,420
موفقیت نصب شده است، پس از
190
00:07:25,420 –> 00:07:27,730
نصب دوباره سعی می کنم چیزی را نصب کنم.
191
00:07:27,730 –> 00:07:29,830
کتابخانه fakir بنابراین من می گویم pip
192
00:07:29,830 –> 00:07:32,920
install fakir بنابراین این
193
00:07:32,920 –> 00:07:35,200
کتابخانه fakir را در پوشه محیط مجازی من نصب می کند
194
00:07:35,200 –> 00:07:37,930
تا من فقط بتوانم این
195
00:07:37,930 –> 00:07:39,700
محیط را فعال کنم و سپس می توانم از آن استفاده کنم بنابراین می
196
00:07:39,700 –> 00:07:41,440
توانید اینجا ببینید که قبلاً
197
00:07:41,440 –> 00:07:44,170
در ویدیوی قبلی من فعال شده است. ما
198
00:07:44,170 –> 00:07:46,510
قبلا zookeeper سرور Kafka و مدیر Kafka را نصب کرده ایم
199
00:07:46,510 –> 00:07:48,880
که در حال
200
00:07:48,880 –> 00:07:51,400
اجرا هستند، بنابراین من به جعبه لینوکس خود در اینجا می روم
201
00:07:51,400 –> 00:07:53,560
و می توانید ببینید که
202
00:07:53,560 –> 00:07:56,020
این zookeeper است این سرور کافکا است و این مدیر خرکوم است
203
00:07:56,020 –> 00:07:57,610
بنابراین هر سه در حال اجرا هستند
204
00:07:57,610 –> 00:08:00,010
شما می توانید اگر می خواهید تنظیمات خود را داشته باشید
205
00:08:00,010 –> 00:08:01,300
یا اگر این مجموعه ویدیویی خاص را دنبال می
206
00:08:01,300 –> 00:08:03,790
کنید، این راهی است که
207
00:08:03,790 –> 00:08:07,420
ما نصب می کنیم، بنابراین من مدیر کافکا خود را باز می کنم
208
00:08:07,420 –> 00:08:09,670
و این مدیر کافکا است.
209
00:08:09,670 –> 00:08:12,070
self turds و این در حال حاضر در اینجا فقط
210
00:08:12,070 –> 00:08:14,350
یک موضوع وجود دارد بنابراین سعی می کنم
211
00:08:14,350 –> 00:08:17,200
یک موضوع جدید در داخل خود
212
00:08:17,200 –> 00:08:20,260
کلاستر turds ایجاد کنم تا بتوانم داده های خود را در اینجا فشار
213
00:08:20,260 –> 00:08:22,930
دهم بنابراین فقط می گویم ایجاد و سپس
214
00:08:22,930 –> 00:08:24,670
نام موضوع بنابراین نام
215
00:08:24,670 –> 00:08:26,980
موضوع کاربر نابود شده خواهد بود و در
216
00:08:26,980 –> 00:08:29,950
این مثال کاری که ما می خواهیم انجام دهیم این است
217
00:08:29,950 –> 00:08:32,080
که در اینجا سناریویی را توضیح می
218
00:08:32,080 –> 00:08:35,650
دهیم که ما یک بروکر واحد با یک
219
00:08:35,650 –> 00:08:38,110
پارتیشن خواهیم داشت بنابراین
220
00:08:38,110 –> 00:08:40,539
زمانی که من موضوع را ایجاد می کنم فقط یک پارتیشن وجود دارد.
221
00:08:40,539 –> 00:08:42,429
تعداد پارتیشنها را یک عدد
222
00:08:42,429 –> 00:08:44,620
میدهم تا ایجاد را بزنم و این کار
223
00:08:44,620 –> 00:08:47,050
برای این کار باعث ایجاد موضوع من میشود، بنابراین میتوانید
224
00:08:47,050 –> 00:08:49,340
ببینید که چقدر آسان است که به بالا نگاه
225
00:08:49,340 –> 00:08:52,010
کنم، بنابراین در داخل خودم خوشه کثیفی وجود دارد،
226
00:08:52,010 –> 00:08:53,900
اکنون دو موضوع وجود دارد: اول، جبرانکننده مصرفکننده
227
00:08:53,900 –> 00:08:56,870
این موضوع از پیش تعریف شده ای است که CAF
228
00:08:56,870 –> 00:08:58,280
به نام ADA ایجاد می کند و من این موضوع جدید را ایجاد کرده ام،
229
00:08:58,280 –> 00:09:00,740
بنابراین اگر برای ثبت نام کاربر کلیک کنم،
230
00:09:00,740 –> 00:09:03,290
می توانید داده های مختلف
231
00:09:03,290 –> 00:09:05,720
مربوط به این کاربر ثبت شده خاص
232
00:09:05,720 –> 00:09:07,310
را مشاهده کنید، همچنین می توانید در اینجا مشاهده کنید که تعداد
233
00:09:07,310 –> 00:09:09,770
پارتیشن ها فقط یک ثانیه است. o فقط صفر است
234
00:09:09,770 –> 00:09:12,110
و اکنون مصرف کننده ای به
235
00:09:12,110 –> 00:09:14,240
آن متصل نیست، بنابراین در اینجا صفر وجود دارد، بنابراین هیچ لیستی در اینجا وجود ندارد،
236
00:09:14,240 –> 00:09:16,010
بنابراین اساساً اینجا
237
00:09:16,010 –> 00:09:17,960
مکانی است که می توانید تمام پیام
238
00:09:17,960 –> 00:09:20,030
هایی را که در جریان هستند مشاهده کنید که مجموع
239
00:09:20,030 –> 00:09:22,160
فعلی افست ها چقدر است. بنابراین، وقتی شروع به انتشار پیام کردیم،
240
00:09:22,160 –> 00:09:24,680
به عمق این چیزها خواهیم رفت
241
00:09:24,680 –> 00:09:27,170
و اکنون
242
00:09:27,170 –> 00:09:29,900
موضوع ایجاد شده است و سپس کاری که
243
00:09:29,900 –> 00:09:32,450
میخواهیم انجام دهیم این است که اولین تولیدکننده خود را بنویسیم،
244
00:09:32,450 –> 00:09:35,630
بنابراین من یک فایل در اینجا ایجاد خواهم کرد که
245
00:09:35,630 –> 00:09:38,660
به عنوان جدید نامیده میشود. و سپس
246
00:09:38,660 –> 00:09:41,590
فایل Python و به عنوان تولید کننده نقطه PI نامیده می شود،
247
00:09:41,590 –> 00:09:45,110
اکنون من اینجا روی نقطه PI سازنده خود کدنویسی می کنم
248
00:09:45,110 –> 00:09:47,420
و اولین چیزی که
249
00:09:47,420 –> 00:09:52,970
باید وارد کنم این است که از کافکا چه چیزی را وارد کنم،
250
00:09:52,970