feat: Enable auto-commit offsets as this is a demo (#22)

Signed-off-by: Katherine Stanley <[email protected]>

Author: katheris

README.md

@@ -41,3 +41,5 @@ Alternatively you can provide a custom path to the properties file using `-Dprop
 If your Kafka is secured you will need to enable the security configuration options in your properties file.
 
 To increase the logging level to debug provide a system property at start time: `-Dlog.level=debug`.
+
+To increase the Kafka client logging level to info provide a system property at start time: `-Dlog.level.kafka=info`.

kafka.properties

@@ -7,7 +7,6 @@ bootstrap.servers=localhost:9092
 ###################################################################
 group.id=my_group
 auto.offset.reset=earliest
-enable.auto.commit=false
 key.deserializer=org.apache.kafka.common.serialization.StringDeserializer
 value.deserializer=org.apache.kafka.common.serialization.StringDeserializer
 

src/main/java/kafka/vertx/demo/WebSocketServer.java

@@ -17,6 +17,7 @@
 import io.vertx.ext.web.handler.StaticHandler;
 import io.vertx.kafka.client.common.TopicPartition;
 import io.vertx.kafka.client.consumer.KafkaConsumer;
+import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -44,6 +45,8 @@ public void start(Promise<Void> startPromise) {
     String propertiesPath = System.getProperty(Main.PROPERTIES_PATH_ENV_NAME, Main.DEFAULT_PROPERTIES_PATH);
     Main.loadKafkaConfig(vertx, propertiesPath)
       .compose(config -> {
+        // Auto commit as this is a demo app
+        config.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true);
         kafkaConfig = config.mapTo(HashMap.class);
         return startWebSocket(router);
       })

src/main/resources/logback.xml

@@ -8,7 +8,7 @@
 
   <logger name="io.netty" level="warn"/>
   <logger name="io.vertx" level="info"/>
-  <logger name="org.apache.kafka" level="error"/>
+  <logger name="org.apache.kafka" level="${log.level.kafka:-error}"/>
   <logger name="org.apache.kafka.clients.NetworkClient" level="warn"/>
 
   <root level="${log.level:-info}">