diff --git a/src/main/kotlin/ltd/hlaeja/listener/AccountListener.kt b/src/main/kotlin/ltd/hlaeja/listener/AccountListener.kt new file mode 100644 index 0000000..1530d1f --- /dev/null +++ b/src/main/kotlin/ltd/hlaeja/listener/AccountListener.kt @@ -0,0 +1,18 @@ +package ltd.hlaeja.listener + +import io.github.oshai.kotlinlogging.KotlinLogging +import ltd.hlaeja.library.accountRegistry.event.AccountMessage +import org.apache.kafka.clients.consumer.ConsumerRecord +import org.springframework.kafka.annotation.KafkaListener +import org.springframework.stereotype.Component + +val log = KotlinLogging.logger {} + +@Component +class AccountListener { + + @KafkaListener(topics = ["account"]) + fun handleRemoteAccountEvent(record: ConsumerRecord) { + log.trace { "Received event: ${record.key()} for user: ${record.value().userId}" } + } +}