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
Raw
Consumer-kafka.java
@Log4j2
@Service
@KafkaListener(id = "temp-id",topics = "#{'${spring.kafka.incoming.topic}'.split(',')}")
public class Consumer {
@KafkaHandler
public void consume(Student student,@Header(KafkaHeaders.OFFSET) String offset)
log.info("offset:" + offset + "Incoming info: "+student);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment