آپاچی کافکا برای مبتدیان - آموزش کافکا توسط Hands-On [ویدئو]

سرفصل ها و درس ها

شروع دوره Getting Started with the Course

• مقدمه و اهداف دوره Course Introduction and Objectives

• پیش نیازها Prerequisites

شروع کار با کافکا Getting Started with Kafka

• مقدمه ای بر کافکا Introduction to Kafka

• اصطلاحات کافکا و APIهای مشتری Kafka Terminologies and Client APIs

کافکا را دانلود و نصب کنید Download and Install Kafka

• کافکا را دانلود و نصب کنید Download and Install Kafka

شناخت اجزای کافکا و درونیات آن - (نظریه + عملی) Understanding Kafka Components and its Internals - (Theory + Hands-On)

• کافکا موضوعات و پارتیشن ها - نظریه Kafka Topics and Partitions - Theory

• یک ZooKeeper/Kafka Broker را در محلی راه اندازی کنید Set Up a ZooKeeper/Kafka Broker in Local

• ایجاد موضوع، تولید و مصرف پیام با استفاده از CLI Create Topic, Produce and Consume Messages Using the CLI

• تولید و مصرف پیام با کلید Produce and Consume Messages with Key

• جبران هزینه های مصرف کننده Consumer Offsets

• گروه های مصرف کننده Consumer Groups

• سیاست ثبت و حفظ تعهد Commit Log and Retention Policy

• کافکا به عنوان یک سیستم جریان توزیع شده Kafka as a Distributed Streaming System

• راه اندازی یک خوشه کافکا به صورت محلی با 3 کارگزار کافکا Setting up a Kafka Cluster in Local with 3 Kafka Brokers

• خوشه کافکا چگونه درخواست های مشتری را توزیع می کند؟ رهبر/پیرو How Kafka Cluster Distributes the Client Requests? Leader/Follower

• کافکا چگونه از دست دادن داده ها را مدیریت می کند؟ Replication and In-Sync-Replica (ISR) How Kafka Handles Data Loss? Replication and In-Sync-Replica(ISR)

• تحمل خطا و استحکام در کافکا Fault Tolerance and Robustness in Kafka

Kafka Producer API - Hands-On Kafka Producer API - Hands-On

• راه اندازی پروژه Project Setup

• ارسال ProducerRecord با استفاده از Producer API Sending ProducerRecord Using Producer API

• تهیه کننده کافکا را بسازید - پیام ها را به صورت همزمان ارسال کنید Build Kafka Producer - Send Messages Synchronously

• اضافه کردن ورود به سیستم با استفاده از LogBack Add Logging Using LogBack

• ارسال پیام به صورت ناهمزمان Sending Messages Asynchronously

• ارسال پیام با کلید Send Messages with Key

• رابط برنامه نویسی برای تولید پیام Programmatic Interface to Produce Messages

• Kafka Producer API - پشت صحنه Kafka Producer API - Behind the Scenes

Kafka Producer API - تنظیمات تحویل پیام تضمین شده Kafka Producer API - Guaranteed Message Delivery Configurations

• تنظیمات API تولید کننده کافکا Kafka Producer API Configurations

• پیکربندی Acks و min.insync.replicas – Hands-On Configuring Acks and min.insync.replicas – Hands-On

• پیکربندی تکرارها و retry.backoff.ms - Hands-On Configuring retries and retry.backoff.ms – Hands-On

Kafka Consumer API – Hands-On Kafka Consumer API – Hands-On

• راه اندازی پروژه Project Setup

• مصرف پیام ها با استفاده از Consumer API - poll() حلقه Consuming Messages using Consumer API - poll() loop

• ساخت مصرف کننده کافکا با استفاده از Consumer API Build Kafka Consumer Using the Consumer API

• auto.offset.reset - اولین در مقابل جدیدترین auto.offset.reset - Earliest Versus Latest

گروه های مصرف کننده و تعادل مجدد مصرف کننده - عملی Consumer Groups and Consumer Rebalance – Hands-On

• مقیاس بندی مصرف کننده با استفاده از گروه های مصرف کننده Scaling the Consumer Using Consumer Groups

• تعادل مجدد مصرف کننده Consumer Rebalance

• Rebalance مصرف کننده و max.poll.interval.ms Consumer Rebalance and max.poll.interval.ms

آفست مصرف کننده - مدیریت افست پیش فرض و دستی - دستی Consumer Offsets - Default and Manual Offset Management – Hands-On

• ارتکاب آفست - استراتژی تعهد پیش فرض آفست Committing Offsets - Default Offset Commit Strategy

• انجام آفست به صورت دستی Manually Committing Offsets

• انجام افست ها به صورت همزمان - با استفاده از commitSync() Committing Offsets Synchronously - Using commitSync()

• انجام آفست ها به صورت ناهمزمان - با استفاده از commitAsync() Committing Offsets Asynchronously - Using commitAsync()

• انجام آفست های خاص - با استفاده از CommitSync() Committing Specific Offsets - using CommitSync()

شنوندگان تعادل مجدد مصرف کننده - دستی Consumer Rebalance Listeners – Hands-On

• مقدمه ای بر Rebalance Listeners Introduction to Rebalance Listeners

• ConsumerRebalanceListener را در Kafka Consumer پیاده سازی کنید Implement ConsumerRebalanceListener in Kafka Consumer

• انجام آفست ها با استفاده از ConsumerRebalanceListener Committing Offsets Using ConsumerRebalanceListener

مصرف کننده کافکا - seekToBeginning()، seekToEnd() و seek() - Hands-On Kafka Consumer - seekToBeginning(), seekToEnd(), and seek() – Hands-On

• مقدمه ()seekToBeginning یا seekToEnd() Introduction to seekToBeginning() or seekToEnd()

• seekToBeginning() و seekToEnd() – Hands-On seekToBeginning() and seekToEnd() – Hands-On

• مقدمه جستجو () Introduction to seek()

• به دنبال یک افست خاص با استفاده از seek() – Hands-On Seek to a Specific Offset Using seek() – Hands-On

سریالایزر و Deserializer سفارشی در کافکا - Hands-On Custom Serializer and Deserializers in Kafka – Hands-On

• چرا سریالایزر/سریالایزر سفارشی کافکا؟ Why Custom Kafka Serializer/Deserializer?

• با استفاده از Jackson ObjectMapper یک سریال ساز سفارشی در تولیدکننده کافکا بسازید Build a Custom Serializer in Kafka Producer Using Jackson ObjectMapper

• تولید کننده کافکا را با استفاده از سریال ساز سفارشی بسازید Build Kafka Producer Using Custom Serializer

• با استفاده از Jackson ObjectMapper یک DeSerializer سفارشی در Producer Kafka بسازید Build a Custom DeSerializer in Kafka Producer Using Jackson ObjectMapper

• ساخت مصرف کننده کافکا با استفاده از سریالایزر سفارشی Build Kafka Consumer Using Custom Serializer

• اشیاء سفارشی را با استفاده از StringSerializer و Jackson ObjectMapper منتشر کنید Publish Custom Objects Using StringSerializer and Jackson ObjectMapper

• اشیاء سفارشی را با استفاده از StringDeserializer و Jackson ObjectMapper مصرف کنید Consume Custom Objects using StringDeserializer and Jackson ObjectMapper