Creating a Serverless Apache Kafka(MSK) publisher using AWS Lambda

Поділитися
Вставка
  • Опубліковано 18 гру 2024

КОМЕНТАРІ • 11

  • @rushikeshkarkhanis7915
    @rushikeshkarkhanis7915 Рік тому +4

    Great tutorial, you explained with Security group configuration. Most of the videos on youtube have public access, which can be vulnerable.
    Thanks for sharing knowledge.

  • @ATHARVA89
    @ATHARVA89 8 місяців тому +1

    hi @knowledge amplifier do you have any video related to testing in data engineering? if not could you suggest some resources

    • @KnowledgeAmplifier1
      @KnowledgeAmplifier1  8 місяців тому

      Hi @ATHARVA89, you can refer this video -- ua-cam.com/video/EVJm3aL7ftY/v-deo.htmlsi=ATOAHV5JO34xSO-C , for more testing related resources , you can refer medium.com/@samzamany/unit-testing-in-data-engineering-a-practical-guide-91196afdf32a

  • @abhishekdubey-p9n
    @abhishekdubey-p9n Рік тому

    you r running loop for Provisioned in lambda can i do with serverless cluster for same i have tried by adding client property's and all but facing some issues (Address family not supported by protocol) and some more pls help me out on this
    And special thanks for this great video

  • @NatureAndMyself
    @NatureAndMyself Рік тому

    I am not sure why it is coming "errorMessage": "Unable to import module 'lambda_function': No module named 'kafka'" ?
    I have tried with S3 and direct uploading .zip file to lambda layer

  • @digitalnomadprabhu
    @digitalnomadprabhu 8 місяців тому

    i creted msk cluster and how to use it in nodejs

  • @KhalidKhan-kr5it
    @KhalidKhan-kr5it Рік тому

    Nice video..I tried but getting error... "errorMessage": "NoBrokersAvailable",
    "errorType": "NoBrokersAvailable",when i run the producer code from cmd it works fine but not with lambda function

    • @ankithashetty2202
      @ankithashetty2202 3 місяці тому

      Even I am facing this issue, were u able to fix this?

    • @sheikhmuhammedshoaib1124
      @sheikhmuhammedshoaib1124 2 місяці тому

      add the api version argument in the KafkaProducer
      KafkaProducer(
      bootstrap_servers=[
      .....
      ],
      api_version = (2, 8, 1)
      )

  • @vipinsharma-jt3qt
    @vipinsharma-jt3qt Рік тому

    Nice tutorial, it would be really helpfull if you can create some tutorial on mutilple zookeeper and kafka broker using docker compose with scheme registy with avro in Python. Done research online but didn't find any solution, If you can do that reallly helpfull. keep creating wonderfull content @KnowledgeAmplifier1.