From d0accb0285577a163525778519475212149fcc92 Mon Sep 17 00:00:00 2001 From: HimajaDhanyamraju2 Date: Mon, 5 Feb 2024 15:57:54 +0530 Subject: [PATCH 1/2] Build check Signed-off-by: HimajaDhanyamraju2 --- consolidator/consolidator_service.bal | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consolidator/consolidator_service.bal b/consolidator/consolidator_service.bal index 68219fa..d1f8940 100644 --- a/consolidator/consolidator_service.bal +++ b/consolidator/consolidator_service.bal @@ -95,7 +95,7 @@ isolated function startConsolidator() returns error? { kafka:ConsumerRecord[] records = check conn:websubEventConsumer->poll(config:POLLING_INTERVAL); foreach kafka:ConsumerRecord currentRecord in records { string lastPersistedData = check string:fromBytes(currentRecord.value); - log:printInfo("websub event received in consolidator",payload=lastPersistedData); + log:printInfo("Websub event received in consolidator",payload=lastPersistedData); error? result = processPersistedData(lastPersistedData); if result is error { log:printError("Error occurred while processing received event ", 'error = result); From deac21dd5a9718831108e3b35fdecd10d99cf97b Mon Sep 17 00:00:00 2001 From: HimajaDhanyamraju2 Date: Mon, 5 Feb 2024 16:08:51 +0530 Subject: [PATCH 2/2] MOSIP-29320: Fixed build failure Signed-off-by: HimajaDhanyamraju2 --- hub/hub_service.bal | 2 -- 1 file changed, 2 deletions(-) diff --git a/hub/hub_service.bal b/hub/hub_service.bal index d8eb445..af7d07e 100644 --- a/hub/hub_service.bal +++ b/hub/hub_service.bal @@ -23,8 +23,6 @@ import kafkaHub.config; import kafkaHub.util; import kafkaHub.healthcheck; import ballerina/jballerina.java; -import kafkaHub.connections as conn; -import ballerinax/kafka; http:Service healthCheckService = service object {