Package com.example.atleastonce.consumer

Class LanguagePreferenceConsumer

java.lang.Object

com.example.atleastonce.consumer.LanguagePreferenceConsumer

@Service
public class LanguagePreferenceConsumer
extends Object

Constructor Summary

Constructors

Constructor	Description
LanguagePreferenceConsumer()

Method Summary

Modifier and Type	Method	Description
void	onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<String,LanguagePreference> record, org.springframework.kafka.support.Acknowledgment ack)	Consumes language preference events with manual acknowledgment.
void	process(LanguagePreference event)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LanguagePreferenceConsumer

public LanguagePreferenceConsumer()

Method Details

onMessage

@KafkaListener(topics="language-preferences",
               groupId="${spring.kafka.consumer.group-id}",
               containerFactory="kafkaListenerContainerFactory")
public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<String,LanguagePreference> record,
 org.springframework.kafka.support.Acknowledgment ack)

Consumes language preference events with manual acknowledgment. The offset is committed only after process() succeeds, guaranteeing at-least-once delivery. Resilience4j retries wrap the downstream call.

process

@Retry(name="languagePreferenceConsumer")
@CircuitBreaker(name="languagePreferenceConsumer")
public void process(LanguagePreference event)