cleanup materializer

Author: zhenik

data-pipeline/http-materializer/pom.xml

@@ -12,11 +12,13 @@
  <artifactId>http-materializer</artifactId>
 
  <dependencies>
+
  <!-- generated avro schema -->
  <dependency>
  <groupId>no.sysco.testing</groupId>
  <artifactId>schema</artifactId>
  </dependency>
+
  <!-- config -->
  <dependency>
  <groupId>com.typesafe</groupId>
@@ -30,7 +32,7 @@
  <version>3.14.0</version>
  </dependency>
 
-
+ <!-- kafka dependencies -->
  <dependency>
  <groupId>org.apache.kafka</groupId>
  <artifactId>kafka-streams</artifactId>
@@ -62,10 +64,10 @@
  <artifactId>slf4j-api</artifactId>
  <scope>test</scope>
  </dependency>
-
  <dependency>
  <groupId>com.github.tomakehurst</groupId>
  <artifactId>wiremock-jre8</artifactId>
+ <scope>test</scope>
  </dependency>
  <dependency>
  <groupId>org.awaitility</groupId>

data-pipeline/http-materializer/src/main/java/no/sysco/testing/kafka/pipeline/materializer/infrastructure/kafka/KafkaMessageMaterializer.java

@@ -38,7 +38,7 @@ public KafkaMessageMaterializer(
  this.transformer = transformer;
  this.sourceTopic = config.kafkaConfig.sourceTopic;
 
- Properties properties = new Properties();
+ final Properties properties = new Properties();
  properties.put(StreamsConfig.APPLICATION_ID_CONFIG, config.name+"steam-processing-v1");
  properties.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, config.kafkaConfig.bootstrapServers);
  properties.put(AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, config.kafkaConfig.schemaRegistryUrl);
@@ -69,11 +69,8 @@ static Topology topology(
  return builder.build();
  }
 
- @Override public void run() {
- kafkaStreams.start();
- }
+ @Override public void run() { kafkaStreams.start(); }
  public void stop() { Optional.ofNullable(kafkaStreams).ifPresent(KafkaStreams::close); }
-
  public KafkaStreams.State getState() {
  return kafkaStreams.state();
  }

data-pipeline/http-materializer/src/main/java/no/sysco/testing/kafka/pipeline/materializer/infrastructure/service/DatabaseWebServiceRest.java

@@ -11,7 +11,6 @@
 import okhttp3.RequestBody;
 import okhttp3.Response;
 
-// todo: proper logging
 public class DatabaseWebServiceRest implements DatabaseWebService {
  private static final Logger log = Logger.getLogger(DatabaseWebServiceRest.class.getName());
  private final String url;
@@ -26,7 +25,7 @@ public DatabaseWebServiceRest(final MaterializerConfig applicationConfig) {
 
  @Override public void saveMessage(final MessageJsonRepresentation message) {
  RequestBody body = RequestBody.create(JSON, message.json());
- Request request =
+  Request request =
  new Request.Builder()
  .addHeader("Accept", "application/json; charset=utf-8")
  .addHeader("Content-Type", "application/json; charset=utf-8")
@@ -41,7 +40,6 @@ public DatabaseWebServiceRest(final MaterializerConfig applicationConfig) {
  log.severe("Request failed with status code: " +statusCode);
  throw new RuntimeException("Request failed with status "+ statusCode);
  }
-
  log.info("Response received successfully: " + statusCode);
  } catch (IOException e) {
  e.printStackTrace();

pom.xml

@@ -68,7 +68,7 @@
  <dependency>
  <groupId>com.typesafe</groupId>
  <artifactId>config</artifactId>
- <version>1.3.2</version>
+ <version>1.3.3</version>
  </dependency>
  <!-- kafka clients -->
  <dependency>