[proxima-direct-io-kafka] improve logging of invalid attributes in ka…

…fka topics
datadrivencz · Oct 23, 2023 · 13f6eba · 13f6eba
1 parent 3bb1458
commit 13f6eba
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/direct/io-kafka/src/main/java/cz/o2/proxima/direct/io/kafka/KafkaStreamElement.java b/direct/io-kafka/src/main/java/cz/o2/proxima/direct/io/kafka/KafkaStreamElement.java
@@ -64,7 +64,8 @@ public StreamElement read(ConsumerRecord<String, byte[]> record, EntityDescripto
         Optional<AttributeDescriptor<Object>> attr =
             entityDesc.findAttribute(attribute, true /* allow reading protected */);
         if (!attr.isPresent()) {
-          log.error("Invalid attribute {} in kafka key {}", attribute, key);
+          log.error(
+              "Invalid attribute {} in kafka key {} for entity {}", attribute, key, entityDesc);
         } else {
           @Nullable
           final Header sequenceIdHeader =