diff --git a/src/main/java/io/zeebe/monitor/zeebe/protobuf/importers/JobProtobufImporter.java b/src/main/java/io/zeebe/monitor/zeebe/protobuf/importers/JobProtobufImporter.java
index 801c40eb..681a9aaa 100644
--- a/src/main/java/io/zeebe/monitor/zeebe/protobuf/importers/JobProtobufImporter.java
+++ b/src/main/java/io/zeebe/monitor/zeebe/protobuf/importers/JobProtobufImporter.java
@@ -19,7 +19,7 @@ public class JobProtobufImporter {
   public JobProtobufImporter(JobRepository jobRepository, MeterRegistry meterRegistry) {
     this.jobRepository = jobRepository;
 
-    counter = Counter.builder("zeebemonitor_importer_job").description("number of processed jobs").register(meterRegistry);
+    this.counter = Counter.builder("zeebemonitor_importer_job").description("number of processed jobs").register(meterRegistry);
   }
 
   public void importJob(final Schema.JobRecord record) {
diff --git a/src/main/java/io/zeebe/monitor/zeebe/protobuf/importers/ProcessAndElementProtobufImporter.java b/src/main/java/io/zeebe/monitor/zeebe/protobuf/importers/ProcessAndElementProtobufImporter.java
index 189dde9c..71b55073 100644
--- a/src/main/java/io/zeebe/monitor/zeebe/protobuf/importers/ProcessAndElementProtobufImporter.java
+++ b/src/main/java/io/zeebe/monitor/zeebe/protobuf/importers/ProcessAndElementProtobufImporter.java
@@ -92,7 +92,8 @@ private void addOrUpdateProcessInstance(final Schema.ProcessInstanceRecord recor
       entity.setStart(timestamp);
       processInstanceRepository.save(entity);
 
-      notificationService.sendCreatedProcessInstance(record.getProcessInstanceKey(), record.getProcessDefinitionKey());
+      notificationService.sendCreatedProcessInstance(
+          record.getProcessInstanceKey(), record.getProcessDefinitionKey());
 
       instanceActivatedCounter.increment();
 
@@ -101,7 +102,8 @@ private void addOrUpdateProcessInstance(final Schema.ProcessInstanceRecord recor
       entity.setEnd(timestamp);
       processInstanceRepository.save(entity);
 
-      notificationService.sendEndedProcessInstance(record.getProcessInstanceKey(), record.getProcessDefinitionKey());
+      notificationService.sendEndedProcessInstance(
+          record.getProcessInstanceKey(), record.getProcessDefinitionKey());
 
       instanceCompletedCounter.increment();
 
@@ -110,7 +112,8 @@ private void addOrUpdateProcessInstance(final Schema.ProcessInstanceRecord recor
       entity.setEnd(timestamp);
       processInstanceRepository.save(entity);
 
-      notificationService.sendEndedProcessInstance(record.getProcessInstanceKey(), record.getProcessDefinitionKey());
+      notificationService.sendEndedProcessInstance(
+          record.getProcessInstanceKey(), record.getProcessDefinitionKey());
 
       instanceTerminatedCounter.increment();
     }
@@ -130,7 +133,8 @@ private void addElementInstance(final Schema.ProcessInstanceRecord record) {
       entity.setProcessDefinitionKey(record.getProcessDefinitionKey());
       entity.setBpmnElementType(record.getBpmnElementType());
       elementInstanceRepository.save(entity);
-      notificationService.sendUpdatedProcessInstance(record.getProcessInstanceKey(), record.getProcessDefinitionKey());
+      notificationService.sendUpdatedProcessInstance(
+          record.getProcessInstanceKey(), record.getProcessDefinitionKey());
 
       elementInstanceCounter.increment();
     }