From a21b77adf9e422835881857767312465718739a2 Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Wed, 15 Dec 2021 14:32:49 +0100
Subject: [PATCH] Add null check for beam ActivePowerReader
---
.../commons/beam/kafka/KafkaActivePowerRecordReader.java | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java
index 4af9053be..f102bee41 100644
--- a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java
+++ b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/kafka/KafkaActivePowerRecordReader.java
@@ -28,11 +28,20 @@ public class KafkaActivePowerRecordReader extends
final Map<String, Object> consumerConfig) {
super();
+ if (bootstrapServer == null) {
+ throw new IllegalArgumentException("bootstrapServer is null");
+ }
+
+ if (inputTopic == null) {
+ throw new IllegalArgumentException("inputTopic is null");
+ }
+
// Check if boostrap server and inputTopic are defined
if (bootstrapServer.isEmpty() || inputTopic.isEmpty()) {
throw new IllegalArgumentException("bootstrapServer or inputTopic missing");
}
+
reader =
KafkaIO.<String, ActivePowerRecord>read()
.withBootstrapServers(bootstrapServer)
--
GitLab