KafkaBackendFix (state initialisation) and exit JVM if exception if r…

…aised (#386)

* ammend wrong state initialization in the kafka backend

* terminate jvm if there is an execution

src/main/java/com/purbon/kafka/topology/CommandLineInterface.java

@@ -141,10 +141,15 @@ private Options buildOptions() {
     return options;
   }
 
-  public static void main(String[] args) throws Exception {
+  public static void main(String[] args) {
     CommandLineInterface cli = new CommandLineInterface();
-    cli.run(args);
-    exit(0);
+    try {
+      cli.run(args);
+      exit(0);
+    } catch (Exception ex) {
+      ex.printStackTrace();
+      exit(1);
+    }
   }
 
   public void run(String[] args) throws Exception {

src/main/java/com/purbon/kafka/topology/backend/KafkaBackend.java

@@ -52,7 +52,7 @@ public void run() {
   @Override
   public void configure(Configuration config) {
     instanceId = config.getJulieInstanceId();
-    latest = new AtomicReference<>();
+    latest = new AtomicReference<>(new BackendState());
 
     consumer = new KafkaBackendConsumer(config);
     consumer.configure();