Skip to content
Snippets Groups Projects
Commit 795f095e authored by Lorenz Boguhn's avatar Lorenz Boguhn
Browse files

Add Types to beam-common KafkaActivePowerRecordReader

parent 9409548c
No related branches found
No related tags found
1 merge request!187Migrate Beam benchmark implementation
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment