package com.highradius.kafka.dto;

import com.highradius.g4.core.common.G4Log;
import com.highradius.g4.core.common.G4LogManager;
import com.highradius.g4.intelliparse.dto.IDPResultDto;
import lombok.RequiredArgsConstructor;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.kafka.support.Acknowledgment;
import org.springframework.stereotype.Component;

@Component
@RequiredArgsConstructor
public class IDPResultConsumer {

    private static final G4Log LOGGER = G4LogManager.getLog(IDPResultConsumer.class);

    @KafkaListener(
        topicPattern = "${spring.kafka.consumer.topic.idp-result}",
        groupId = "${spring.kafka.consumer.group-id}",
        containerFactory = "idpResultKafkaListenerContainerFactory"
    )
    public void consumeIDPResult(IDPResultDto message, Acknowledgment acknowledgment) {
        LOGGER.info("Received IDPResultDto from Kafka: " + message);
        acknowledgment.acknowledge();  // Manual commit
    }
}