Code & Setup an abgeleitete Versionen angeglichen

diff --git a/.dockerignore b/.dockerignore
new file mode 100644 (file)
index 0000000..1ad9963
--- /dev/null
+++ b/.dockerignore
@@ -0,0 +1,2 @@
+*
+!target/*.jar

diff --git a/.maven-dockerexclude b/.maven-dockerexclude
new file mode 100644 (file)
index 0000000..72e8ffc
--- /dev/null
+++ b/.maven-dockerexclude
@@ -0,0 +1 @@
+*

diff --git a/.maven-dockerinclude b/.maven-dockerinclude
new file mode 100644 (file)
index 0000000..fd6cecd
--- /dev/null
+++ b/.maven-dockerinclude
@@ -0,0 +1 @@
+target/*.jar

diff --git a/pom.xml b/pom.xml
index 987adce..ad7f17a 100644 (file)
--- a/pom.xml
+++ b/pom.xml
@@ -14,6 +14,7 @@
   <groupId>de.juplo.kafka</groupId>
   <artifactId>simple-producer</artifactId>
   <name>Super Simple Producer</name>
+  <description>A Simple Producer, programmed with pure Java, that sends messages via Kafka</description>
   <version>1.0-SNAPSHOT</version>
 
   <properties>
@@ -66,6 +67,10 @@
           </archive>
         </configuration>
       </plugin>
+      <plugin>
+        <groupId>pl.project13.maven</groupId>
+        <artifactId>git-commit-id-plugin</artifactId>
+      </plugin>
       <plugin>
         <groupId>io.fabric8</groupId>
         <artifactId>docker-maven-plugin</artifactId>

diff --git a/src/main/java/de/juplo/kafka/ExampleProducer.java b/src/main/java/de/juplo/kafka/ExampleProducer.java
index 51178f5..06e14ef 100644 (file)
--- a/src/main/java/de/juplo/kafka/ExampleProducer.java
+++ b/src/main/java/de/juplo/kafka/ExampleProducer.java
@@ -16,9 +16,9 @@ public class ExampleProducer
   private final String topic;
   private final Producer<String, String> producer;
 
-  private long produced = 0;
   private volatile boolean running = true;
   private volatile boolean done = false;
+  private long produced = 0;
 
   public ExampleProducer(String broker, String topic, String clientId)
   {
@@ -39,13 +39,16 @@ public class ExampleProducer
 
     try
     {
-      for (; running ; i++)
+      for (; running; i++)
       {
         send(Long.toString(i%10), Long.toString(i));
         Thread.sleep(500);
       }
     }
-    catch (InterruptedException e) {}
+    catch (Exception e)
+    {
+      log.error("{} - Unexpected error: {}!", id, e.toString());
+    }
     finally
     {
       log.info("{}: Closing the KafkaProducer", id);
@@ -99,9 +102,8 @@ public class ExampleProducer
 
     long now = System.currentTimeMillis();
     log.trace(
-        "{} - Queued #{} key={} latency={}ms",
+        "{} - Queued message with key={} latency={}ms",
         id,
-        value,
         record.key(),
         now - time
     );