Skip to content
Snippets Groups Projects
Commit a78f5df9 authored by Sören Henning's avatar Sören Henning
Browse files

Suppress and fix PMD/Spotbugs warnings

parent 0254266a
No related branches found
No related tags found
No related merge requests found
Pipeline #6345 failed
...@@ -12,8 +12,8 @@ import org.apache.kafka.clients.consumer.ConsumerConfig; ...@@ -12,8 +12,8 @@ import org.apache.kafka.clients.consumer.ConsumerConfig;
*/ */
public class AbstractPipeline extends Pipeline { public class AbstractPipeline extends Pipeline {
private static final String KAFKA_CONFIG_SPECIFIC_AVRO_READER = "specific.avro.reader"; private static final String KAFKA_CONFIG_SPECIFIC_AVRO_READER = "specific.avro.reader"; // NOPMD
private static final String KAFKA_CONFIG_SCHEMA_REGISTRY_URL = "schema.registry.url"; private static final String KAFKA_CONFIG_SCHEMA_REGISTRY_URL = "schema.registry.url"; // NOPMD
protected final String inputTopic; protected final String inputTopic;
protected final String bootstrapServer; protected final String bootstrapServer;
// Application Configurations // Application Configurations
......
...@@ -44,7 +44,7 @@ public class AggregatedActivePowerRecordCoder extends Coder<AggregatedActivePowe ...@@ -44,7 +44,7 @@ public class AggregatedActivePowerRecordCoder extends Coder<AggregatedActivePowe
@Override @Override
public List<? extends Coder<?>> getCoderArguments() { public List<? extends Coder<?>> getCoderArguments() {
return null; return List.of();
} }
@Override @Override
......
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