diff --git a/examples/custom-kafka-connector-adapter/src/main/java/com/lightstreamer/kafka_connector/examples/CustomKafkaConnectorAdapter.java b/examples/custom-kafka-connector-adapter/src/main/java/com/lightstreamer/kafka_connector/examples/CustomKafkaConnectorAdapter.java index 41dd1f07..1a0bc46e 100644 --- a/examples/custom-kafka-connector-adapter/src/main/java/com/lightstreamer/kafka_connector/examples/CustomKafkaConnectorAdapter.java +++ b/examples/custom-kafka-connector-adapter/src/main/java/com/lightstreamer/kafka_connector/examples/CustomKafkaConnectorAdapter.java @@ -12,7 +12,7 @@ public class CustomKafkaConnectorAdapter extends KafkaConnectorMetadataAdapter { @Override public void postInit(Map parameters, File adapterDir) { - System.out.println("Custom KafkaConnector Adapter initialized"); + System.out.println("###### Custom KafkaConnector Adapter initialized ######"); } @Override