From fbab3a0f230522d790becfae4c76e95b03359c81 Mon Sep 17 00:00:00 2001
From: Alexander <alexander.bryksin@yandex.ru>
Date: Thu, 14 Apr 2022 10:20:51 +0300
Subject: [PATCH] feature: add bank account mongo projection

---
 .../bankAccount/projection/BankAccountMongoProjection.java      | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/main/java/com/eventsourcing/bankAccount/projection/BankAccountMongoProjection.java b/src/main/java/com/eventsourcing/bankAccount/projection/BankAccountMongoProjection.java
index 98d9f06..811544d 100644
--- a/src/main/java/com/eventsourcing/bankAccount/projection/BankAccountMongoProjection.java
+++ b/src/main/java/com/eventsourcing/bankAccount/projection/BankAccountMongoProjection.java
@@ -27,6 +27,7 @@ public class BankAccountMongoProjection {
             groupId = "${microservice.kafka.groupId}",
             concurrency = "${microservice.kafka.default-concurrency}")
     public void bankAccountMongoProjectionListener(@Payload byte[] data, ConsumerRecordMetadata meta, Acknowledgment ack) {
+        log.info("(BankAccountMongoProjection) topic: {}, offset: {}, partition: {}, timestamp: {}", meta.topic(), meta.offset(), meta.partition(), meta.timestamp());
         log.info("(BankAccountMongoProjection) data: {}", new String(data));
 
         try {
@@ -35,6 +36,7 @@ public class BankAccountMongoProjection {
             log.info("ack events: {}", Arrays.toString(events));
         } catch (Exception e) {
             ack.nack(100);
+            log.error("(BankAccountMongoProjection) topic: {}, offset: {}, partition: {}, timestamp: {}", meta.topic(), meta.offset(), meta.partition(), meta.timestamp());
             log.error("bankAccountMongoProjectionListener: {}", e.getMessage());
         }
     }