X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=influxlogger%2Fsrc%2Fmain%2Fjava%2Forg%2Foran%2Fpmlog%2FDataFromKafkaTopic.java;h=16f5f2a88cfe32394b970f1d1942408bd14298b5;hb=331535e4fea69fbdcf3c74cc1cdfe8b05c9080f4;hp=2d08cde8150641de7c809c0de3e3ca62ab896746;hpb=6dfbff6834c3a9da2d8f06b15eb94048cbad2d88;p=nonrtric%2Fplt%2Franpm.git diff --git a/influxlogger/src/main/java/org/oran/pmlog/DataFromKafkaTopic.java b/influxlogger/src/main/java/org/oran/pmlog/DataFromKafkaTopic.java index 2d08cde..16f5f2a 100644 --- a/influxlogger/src/main/java/org/oran/pmlog/DataFromKafkaTopic.java +++ b/influxlogger/src/main/java/org/oran/pmlog/DataFromKafkaTopic.java @@ -23,6 +23,7 @@ package org.oran.pmlog; import java.io.ByteArrayInputStream; import java.util.zip.GZIPInputStream; +import lombok.Getter; import lombok.ToString; import org.apache.kafka.common.header.Header; @@ -31,8 +32,11 @@ import org.slf4j.LoggerFactory; @ToString public class DataFromKafkaTopic { + @Getter private final byte[] key; + @Getter private final byte[] value; + @Getter private String stringValue = null; private static final Logger logger = LoggerFactory.getLogger(DataFromKafkaTopic.class);