From 795f095e87a0036215d0723736c4cdb4b92aa871 Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Tue, 7 Dec 2021 19:17:39 +0100
Subject: [PATCH] Add Types to beam-common KafkaActivePowerRecordReader
---
.../commons/beam/kafka/KafkaActivePowerRecordReader.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 07b52be5d..3c6274bc5 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
@@ -26,7 +26,7 @@ public class KafkaActivePowerRecordReader extends
*/
@SuppressWarnings({"unchecked", "rawtypes"})
public KafkaActivePowerRecordReader(final String bootstrapServer, final String inputTopic,
- final Map consumerConfig) {
+ final Map<String, Object> consumerConfig) {
super();
// Check if boostrap server and inputTopic are defined
--
GitLab