Skip to content

Instantly share code, notes, and snippets.

@pradeekpmohandas

pradeekpmohandas/Consumer-kafka.java

Last active August 1, 2020 18:12
Show Gist options
  • Save pradeekpmohandas/485c827cfa82aa9caa886f30341da8c8 to your computer and use it in GitHub Desktop.
Save pradeekpmohandas/485c827cfa82aa9caa886f30341da8c8 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. pradeekpmohandas revised this gist Aug 1, 2020. 1 changed file with 3 additions and 4 deletions.
    7 changes: 3 additions & 4 deletions Consumer-kafka.java
    View file
    Original file line number Diff line number Diff line change
    @@ -1,11 +1,10 @@
    @Log4j2
    @Service
    @KafkaListener(id = "temp-id", groupId = "temp-groupID", topics = "#{'${spring.kafka.incoming.topic}'.split(',')}")
    @KafkaListener(id = "temp-id",topics = "#{'${spring.kafka.incoming.topic}'.split(',')}")
    public class Consumer {

    @KafkaHandler
    public void consume(Student student, @Header(KafkaHeaders.RECEIVED_TOPIC) String topicName,
    @Header(KafkaHeaders.OFFSET) String offset)
    log.info(" topic: " + topicName + ", offset: " + offset + "Incoming info: "+student);
    public void consume(Student student,@Header(KafkaHeaders.OFFSET) String offset)
    log.info("offset:" + offset + "Incoming info: "+student);
    }
    }
  2. pradeekpmohandas revised this gist Aug 1, 2020. 1 changed file with 5 additions and 8 deletions.
    13 changes: 5 additions & 8 deletions Consumer-kafka.java
    View file
    Original file line number Diff line number Diff line change
    @@ -3,12 +3,9 @@
    @KafkaListener(id = "temp-id", groupId = "temp-groupID", topics = "#{'${spring.kafka.incoming.topic}'.split(',')}")
    public class Consumer {


    @KafkaHandler
    public void consume(Student student, @Header(KafkaHeaders.RECEIVED_TOPIC) String topicName, @Header(KafkaHeaders.OFFSET) String offset){
    log.info(" topic: " + topicName + ", offset: " + offset + "Incoming info: "+student);
    }



    @KafkaHandler
    public void consume(Student student, @Header(KafkaHeaders.RECEIVED_TOPIC) String topicName,
    @Header(KafkaHeaders.OFFSET) String offset)
    log.info(" topic: " + topicName + ", offset: " + offset + "Incoming info: "+student);
    }
    }
  3. pradeekpmohandas created this gist Aug 1, 2020.
    14 changes: 14 additions & 0 deletions Consumer-kafka.java
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,14 @@
    @Log4j2
    @Service
    @KafkaListener(id = "temp-id", groupId = "temp-groupID", topics = "#{'${spring.kafka.incoming.topic}'.split(',')}")
    public class Consumer {


    @KafkaHandler
    public void consume(Student student, @Header(KafkaHeaders.RECEIVED_TOPIC) String topicName, @Header(KafkaHeaders.OFFSET) String offset){
    log.info(" topic: " + topicName + ", offset: " + offset + "Incoming info: "+student);
    }



    }