diff --git a/examples/kafka-hub/hub/modules/persistence/persistence.bal b/examples/kafka-hub/hub/modules/persistence/persistence.bal index 7ac8c6e2..a799ecff 100644 --- a/examples/kafka-hub/hub/modules/persistence/persistence.bal +++ b/examples/kafka-hub/hub/modules/persistence/persistence.bal @@ -15,9 +15,9 @@ // under the License. import ballerina/websubhub; +import ballerinax/kafka; import kafkaHub.config; import kafkaHub.connections as conn; -import ballerinax/kafka; public isolated function addRegsiteredTopic(websubhub:TopicRegistration message) returns error? { check updateHubState(message);