Update EmbeddedExample.java

Hello,

The line “EmbeddedKafkaConfig kafkaConfig = EmbeddedKafkaConfig.defaultConfig();” does not work. To call the defaultConfig function you have to put :
EmbeddedKafkaConfig kafkaConfig = EmbeddedKafkaConfig$.MODULE$.defaultConfig();

It's a good idea ?

Best regards,
Mohamed

Author: MohamedEL59

example-java/src/main/java/com/softwaremill/kmq/example/embedded/EmbeddedExample.java

@@ -34,7 +34,7 @@ public static void main(String[] args) throws InterruptedException, IOException
         KmqConfig kmqConfig = new KmqConfig("queue", "markers", "kmq_client",
                 "kmq_redelivery", Duration.ofSeconds(10).toMillis(), 1000);
 
-        EmbeddedKafkaConfig kafkaConfig = EmbeddedKafkaConfig.defaultConfig();
+        EmbeddedKafkaConfig kafkaConfig = EmbeddedKafkaConfig$.MODULE$.defaultConfig();
         KafkaClients clients = new KafkaClients("localhost:" + kafkaConfig.kafkaPort());
 
         EmbeddedKafka$.MODULE$.start(kafkaConfig);
@@ -122,4 +122,4 @@ private static void startInBackground(Runnable r) {
         t.setDaemon(true);
         t.start();
     }
-}
+}