From b7e4e032e2fa0035f2f680d5bc2dcc51f212ff69 Mon Sep 17 00:00:00 2001 From: Gianluca Date: Tue, 12 Mar 2024 17:00:43 +0100 Subject: [PATCH] Improve postInit message in the sample CustomKafkaConnectorAdapter class --- .../kafka_connector/examples/CustomKafkaConnectorAdapter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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