Creating Stream processing application using Spark and Kafka in Scala | Spark Streaming Course

Поделиться
HTML-код
  • Опубликовано: 26 янв 2025

Комментарии • 23

  • @ScholarNest
    @ScholarNest  4 года назад

    Want to learn more Big Data Technology courses. You can get lifetime access to our courses on the Udemy platform. Visit the below link for Discounts and Coupon Code.
    www.learningjournal.guru/courses/

  • @bradydyson65
    @bradydyson65 2 года назад +2

    Finally! A teacher who knows how to communicate. The pauses, cadence, and questions are very helpful and reassuring, and the explanations were thorough and clear. This was very helpful and a joy to watch. Thank you so much.

  • @oleg20century
    @oleg20century 9 месяцев назад

    thanks, it is great guide and simple at same time

  • @dwivedys
    @dwivedys Год назад

    Excellent!

  • @bradydyson65
    @bradydyson65 2 года назад +1

    Thanks again for the tutorial. The only major issues I had were compatibility issues and an error that said that my checkpoint directory did not exist. I tried several directories, and they definitely existed! I think it was maybe a permissions problem.

    • @Mado44555
      @Mado44555 8 месяцев назад

      how did you solve it ?

  • @MiguelGonzalez-ze2pd
    @MiguelGonzalez-ze2pd Год назад

    This is great. Can you provide some real world examples on why would we need such solution? Thanks

  • @sailpawar6164
    @sailpawar6164 2 года назад +1

    kafka integration?

  • @Mado44555
    @Mado44555 8 месяцев назад

    thank you for explaining
    i was looking for a start example to get what it is but videos were like explaining to some experts
    well i figured out to follow your steps , after running the code and done the ncat command i m getting errors and first one is: "chk-point-dir"
    any help

  • @mitsaki_drink_tea
    @mitsaki_drink_tea 2 года назад

    thanks you are a good teacher

  • @litenp
    @litenp 3 года назад

    How to install ncat on windows. is this a new software we need to be installed 16:17 mins

    • @ScholarNest
      @ScholarNest  3 года назад

      It may not be required. I used it only for one example. You can just watch the example and learn. Other examples don't need it.

  • @swapnalichavan4077
    @swapnalichavan4077 2 года назад

    How we can use multithreading in streaming with executors

  • @YogaPrakashaBhanu
    @YogaPrakashaBhanu 4 месяца назад

    sir, I want to know how we can apply streaming framework to a database lets say mysql, how can we read new data arrived at particular table without overlapping with new arrivals with old rows at the table

    • @ScholarNest
      @ScholarNest  4 месяца назад

      Streaming ingestion using Spark from databases such as MySQL is not possible and not recommended.
      Why?
      Because parallel streaming ingestion will not scale with MySQL and put a huge workload on the database.
      So we can use some ingestion tool such as ADF or fivetran etc to bring data from MySQL to directory and use Spark streaming to read from directory.
      It will be two step process.
      ADD and fivetran etc can handle CDC and ingest only new records

  • @chiragkalra438
    @chiragkalra438 3 года назад +1

    Did anyone see kafka example in this ??

  • @sikatacoulibaly792
    @sikatacoulibaly792 3 года назад +2

    thanks for this video, but I some questions have. Why you created the file log4j.properties? It is necessary?

  • @YEO19901
    @YEO19901 3 года назад

    Super

  • @salmansayyad4522
    @salmansayyad4522 3 года назад

    Sir I need the same code in this video i.e scala. Why don't you put the link for the code you use in every video? I am struggling to write code by looking at screen, Please help!

  • @NirajKumar-fu7tt
    @NirajKumar-fu7tt 4 года назад

    Sir...you should also share your codes

    • @ScholarNest
      @ScholarNest  4 года назад

      Which code?
      You can find it on website.
      www.learningjournal.guru/courses/

  • @vetiarvind
    @vetiarvind 9 дней назад

    Nice tutorial but dude, it's version (ver-shun) not versun. Also, why do you keep saying good and great when you're just playing with some code?
    Can you also talk a bit about Coursier or Maven and which artifact repo you're pulling from?