Maheshwar Ligade maheshwarLigade

🐢

Slow To respond

Learner & Problem Solver. Full Stack Java Developer, StackOverflower, Curious about Open source, Machine learning & AI

maheshwarLigade / GreetMessageConsumer.java

Last active July 26, 2021 04:46

	package com.techwasti.kafkaex;

	import io.micronaut.configuration.kafka.annotation.KafkaKey;
	import io.micronaut.configuration.kafka.annotation.KafkaListener;
	import io.micronaut.configuration.kafka.annotation.Topic;
	import io.micronaut.configuration.kafka.annotation.OffsetReset;

	@KafkaListener(offsetReset = OffsetReset.EARLIEST)
	public class GreetMessageConsumer {