Adjust the emdedded Kafka service to the updated interface from Camel 3.7
@@ -78,12 +78,18 @@ public class EmbeddedKafkaService implements KafkaService {
return null;
}
+ @Override
+ public void registerProperties() {
+ // NO-OP
+ }
+
@Override
public void initialize() {
if (!started) {
cluster.start();
started = true;
+ registerProperties();
LOG.info("Kafka bootstrap server running at address {}", getBootstrapServers());
}
}
