Code Review
/
nonrtric
/
plt
/
ranpm.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Improve Test coverage of InfluxLogger
[nonrtric/plt/ranpm.git]
/
influxlogger
/
src
/
main
/
java
/
org
/
oran
/
pmlog
/
DataFromKafkaTopic.java
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
(file)
--- 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 java.io.ByteArrayInputStream;
import java.util.zip.GZIPInputStream;
+import lombok.Getter;
import lombok.ToString;
import org.apache.kafka.common.header.Header;
import lombok.ToString;
import org.apache.kafka.common.header.Header;
@@
-31,8
+32,11
@@
import org.slf4j.LoggerFactory;
@ToString
public class DataFromKafkaTopic {
@ToString
public class DataFromKafkaTopic {
+ @Getter
private final byte[] key;
private final byte[] key;
+ @Getter
private final byte[] value;
private final byte[] value;
+ @Getter
private String stringValue = null;
private static final Logger logger = LoggerFactory.getLogger(DataFromKafkaTopic.class);
private String stringValue = null;
private static final Logger logger = LoggerFactory.getLogger(DataFromKafkaTopic.class);