kafka_consumer.bal

function createMessageConsumer(websubhub:VerifiedSubscription message) returns kafka:Consumer|error {
    string groupName = string `${message.hubTopic}_${message.hubCallback}`;
    kafka:ConsumerConfiguration consumerConfiguration = {
        groupId: groupName,
        topics: [message.hubTopic],
        // turn-off the auto offset commit
        autoCommit: false
    };
    return check new ("localhost:9092", consumerConfiguration);  
}