Skip to content

Commit

Permalink
Update subscriber-id construction logic
Browse files Browse the repository at this point in the history
  • Loading branch information
ayeshLK committed Jan 9, 2024
1 parent 26006f2 commit 99cbb6a
Showing 1 changed file with 3 additions and 13 deletions.
16 changes: 3 additions & 13 deletions examples/kafka-hub/hub/modules/util/util.bal
Original file line number Diff line number Diff line change
Expand Up @@ -24,9 +24,8 @@ import ballerina/log;
# + topic - The `topic` which subscriber needs to subscribe
# + callbackUrl - Subscriber callback URL
# + return - Generated subscriber Id for the subscriber
public isolated function generateSubscriberId(string topic, string callbackUrl) returns string {
string idValue = topic + ":::" + callbackUrl;
return nomalizeString(idValue);
public isolated function generatedSubscriberId(string topic, string callbackUrl) returns string {
return string `${topic}___${callbackUrl}`;
}

# Generates a group name for the kafka-consumer.
Expand All @@ -35,16 +34,7 @@ public isolated function generateSubscriberId(string topic, string callbackUrl)
# + callbackUrl - Subscriber callback URL
# + return - Generated consumer group name the subscriber
public isolated function generateGroupName(string topic, string callbackUrl) returns string {
string idValue = topic + ":::" + callbackUrl + ":::" + time:monotonicNow().toBalString();
return nomalizeString(idValue);
}

# Normalizes a `string` by replacing special characters with `_`.
#
# + baseString - `string` to be normalized
# + return - Normalized `string`
isolated function nomalizeString(string baseString) returns string {
return re `[^a-zA-Z0-9]`.replaceAll(baseString, "_");
return string `${topic}___${callbackUrl}___${time:monotonicNow().toBalString()}`;
}

# Generates a random `string` of 10 characters
Expand Down

0 comments on commit 99cbb6a

Please sign in to comment.