Kafka Producer Callback in Java [Apache Kafka Tutorial #12]

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

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

  • @SonuGupta-ei8sv
    @SonuGupta-ei8sv Год назад

    Your way of explaining the concepts are amazing.⭐⚡🔥

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

    Good initiative, u are so clear,pls make more videos in kafka transactions too and best practices in kafka

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

    Thanks for the nice tutorial

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

    Please make more videos on Kafka like methods used in consumer etc...

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

    just a suggestion it would be nice and helpful if you share the link of written code so that if in case any error occurs (Typo or missing any line or keyword) we might refer the code file and correct the error

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

    Thanks a lot

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

    hello, how do i run kafka in android studio with gradle dependencies
    can u please help me with one simple example.

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

      It should be same as intellij

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

      @@Codetuber No ..when ever i create a kafka object its getting crash in android studio

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

      @@Codetuber can u create one small example of a kafka ,how it works on android studio,it will be a helpfull to us

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

      i have used the below code in android studio with gradle ,and also i have connected with kafka.
      When ever i run the code i will get error on below line
      final KafkaProducer producer=new KafkaProducer(props)
      can u please look after it a give me a solution for it .
      code:
      public static void main(String args[]){
      Properties props = new Properties();
      props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
      props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
      props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, JsonSerializer.class.getName());
      final KafkaProducer producer=new KafkaProducer(props);
      ProducerRecordrecord=new ProducerRecord("student","key1","print1");
      producer.send(record);
      producer.flush();
      producer.close();
      }