در حال حاضر محصولی در سبد خرید شما وجود ندارد.
این دوره شما را از طریق مفاهیم کافکا گام به گام راه می دهد. ما درونی کافکا را از منظر نظری بررسی خواهیم کرد و به دنبال آن دست ها در کاوش داخلی کافکا قرار داریم. سپس ما در مورد ساخت تولید کننده کافکا برای تولید پیام ها به کافکا با استفاده از API تولید کننده یاد خواهیم گرفت. این به دنبال یادگیری تنظیمات مختلفی است که تحویل پیام را به Kafka تضمین می کند و مصرف کننده Kafka را برای خواندن پیام های Kafka با استفاده از API مصرف کننده می خواند.
در بخش بعدی، ما در مورد گروه های مصرف کننده و تعادل مصرف کننده، تخفیف مصرف کنندگان یاد خواهیم گرفت و استراتژی های مختلفی که برای مصرف کننده در دسترس هستند برای تعهدات در دسترس قرار می گیرند.
بعد، ما در مورد شنوندگان تجدید نظر مصرف کننده یاد می گیریم تا قبل از لغو پارتیشن یا برخی از وظایف ابتدایی در حین تخصیص پارتیشن، پاکسازی شود. سپس در مورد تکنیک های مختلف از مصرف کننده یاد بگیرید تا به دنبال یک جبران متفاوت باشد.
و در نهایت، ما کد گذاری می کنیم و یاد می گیریم چگونه به ساخت سریال سفارشی / deserializer سفارشی و ادغام آن را به تولید کننده / مصرف کننده Kafka ما.
توسط پایان دوره، شما درک کامل Apache Kafka را خواهید داشت و قادر به ساخت برنامه های کاربردی مصرف کننده Kafka با استفاده از جاوا خواهید بود.
بسته نرم افزاری کامل کد برای این دوره در https://github.com/packtpublishing در دسترس است Apache-Kafka-for-Beginners --- یادگیری Kafka-by-hands-on
عنوان اصلی : Apache Kafka for Beginners - Learn Kafka by Hands-On
سرفصل های دوره :
شروع دوره:
مقدمه و اهداف دوره
پیش نیازها
شروع با کافکا:
مقدمه ای بر کافکا
اصطلاحات کافکا و APIهای مشتری
کافکا را دانلود و نصب کنید:
کافکا را دانلود و نصب کنید
درک اجزای کافکا و درونیات آن - (نظریه + عملی) :
موضوعات و پارتیشن های کافکا - نظریه
یک ZooKeeper/Kafka Broker را در محلی راه اندازی کنید
ایجاد موضوع، تولید و مصرف پیام با استفاده از CLI
تولید و مصرف پیام با کلید
تغییرهای مصرف کننده
گروه های مصرف کننده
Commit Log و سیاست حفظ
کافکا به عنوان یک سیستم پخش جریانی توزیع شده
راه اندازی یک خوشه کافکا به صورت محلی با 3 کارگزار کافکا
خوشه کافکا چگونه درخواست های مشتری را توزیع می کند؟ رهبر/پیرو
کافکا چگونه از دست دادن داده ها را مدیریت می کند؟ Replication and In-Sync-Replica (ISR)
تحمل خطا و استحکام در کافکا
Kafka Producer API - Hands-On:
تنظیم پروژه
ارسال ProducerRecord با استفاده از Producer API
تهیه کننده کافکا را بسازید - پیام ها را به صورت همزمان ارسال کنید
با استفاده از LogBack ورود به سیستم را اضافه کنید
ارسال پیام به صورت ناهمزمان
ارسال پیام با کلید
رابط برنامه ای برای تولید پیام
Kafka Producer API - پشت صحنه
Kafka Producer API - پیکربندی‌های تضمین شده تحویل پیام:
پیکربندی های API سازنده Kafka
پیکربندی Acks و min.insync.replicas - Hands-On
پیکربندی تلاش های مجدد و retry.backoff.ms - Hands-On
Kafka Consumer API - Hands-On:
تنظیم پروژه
مصرف پیام ها با استفاده از Consumer API - poll() loop
ساخت مصرف کننده کافکا با استفاده از Consumer API
auto.offset.reset - قدیمی ترین در مقابل جدیدترین
گروه های مصرف کننده و تعادل مجدد مصرف کننده - عملی:
مقیاس سازی مصرف کننده با استفاده از گروه های مصرف کننده
تعادل مجدد مصرف کننده
تعادل مجدد مصرف کننده و max.poll.interval.ms
تغییرهای مصرف کننده - مدیریت آفست پیش فرض و دستی - دستی:
تعهد آفست ها - استراتژی تعهد افست پیش فرض
تعهد دستی آفست
تعهد کردن Offset ها به صورت همزمان - با استفاده از commitSync()
تعهد کردن آفست ها به صورت ناهمزمان - با استفاده از commitAsync()
تعهد کردن آفست های خاص - با استفاده از CommitSync()
شنوندگان تعادل مجدد مصرف کننده - دستی:
مقدمه ای بر Rebalance Listeners
ConsumerRebalanceListener را در مصرف کننده کافکا پیاده کنید
تعهد به جبران با استفاده از ConsumerRebalanceListener
مصرف کننده کافکا - seekToBeginning()، seekToEnd() و seek() - Hands-On:
معرفی به seekToBeginning() یا seekToEnd()
seekToBeginning() و seekToEnd() - Hands-On
مقدمه به seek()
جستجوی یک افست خاص با استفاده از seek() - Hands-On
سریال ساز سفارشی و دسریالایزر در کافکا - Hands-On:
چرا سریالساز/دسریالایزر سفارشی کافکا؟
با استفاده از Jackson ObjectMapper یک سریال ساز سفارشی در تولیدکننده کافکا بسازید
تولید کننده کافکا را با استفاده از سریالساز سفارشی بسازید
با استفاده از Jackson ObjectMapper، یک DeSerializer سفارشی در تولیدکننده Kafka بسازید
ساخت مصرف کننده کافکا با استفاده از سریال ساز سفارشی
اشیاء سفارشی را با استفاده از StringSerializer و Jackson ObjectMapper منتشر کنید
اشیاء سفارشی را با استفاده از StringDeserializer و Jackson ObjectMapper مصرف کنید
Apache Kafka for Beginners - Learn Kafka by Hands-On
در این روش نیاز به افزودن محصول به سبد خرید و تکمیل اطلاعات نیست و شما پس از وارد کردن ایمیل خود و طی کردن مراحل پرداخت لینک های دریافت محصولات را در ایمیل خود دریافت خواهید کرد.
