Skip to content

fitiz/cs-pg-consumer

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

15 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Challenge service Kafka consumer for PostgreSQL

  • Kafka consumer for storing user step counts in PostgreSQL
@KafkaListener(
            topics = {"${prop.config.broker-properties.step-count-topic}"},
            groupId = "${prop.config.broker-properties.step-count-topic-pg-consumer-group-id}",
            properties = {"spring.json.value.default.type=com.fitiz.cspgconsumer.model.StepCountUpdateData"})
    public void stepCountPgConsumer(ConsumerRecord<String, StepCountUpdateData> record) {
        var stepCountUpdateData = record.value();
        log.info("Step count consumed, [user: {}, step count: {}]", stepCountUpdateData.username(), stepCountUpdateData.steps());
        boolean updatedStepCount = leaderboardPgRepository.updateStepCount(stepCountUpdateData.userId(),
                stepCountUpdateData.steps());
        if (!updatedStepCount) {
            log.error("Failed to update step count for user: {}", stepCountUpdateData.username());
            return;
        }
        log.info("Step count saved to DB...");
    }

About

No description, website, or topics provided.

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published