diff --git a/loggroup-lambda-connector/Readme.md b/loggroup-lambda-connector/Readme.md
index 2041cff..5dd9397 100644
--- a/loggroup-lambda-connector/Readme.md
+++ b/loggroup-lambda-connector/Readme.md
@@ -71,6 +71,10 @@ Lambda Destination ARN :- This specifies ARN of the Lambda function. Also you ha
 
 Kinesis Destination ARN :- This specifies the ARN of the kinesis Stream.
 
+**FILTER_NAME** : A name for the subscription filter. Will use `SumoLGLBDFilter` to set an empty filter if none is provided since [PutSubscriptionFilter](https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutSubscriptionFilter.html) requires this parameter.
+
+**FILTER_PATTERN** : Filter pattern for subscribing to a filtered stream of log events. Default will be an empty pattern `""` since [PutSubscriptionFilter](https://docs.aws.amazon.com/AmazonCloudWatchLogs/latest/APIReference/API_PutSubscriptionFilter.html) requires this parameter.
+
 **ROLE_ARN** : This is used when subscription destination ARN is kinesis firehose stream.
 
 ### For Developers
diff --git a/loggroup-lambda-connector/sam/packaged.yaml b/loggroup-lambda-connector/sam/packaged.yaml
index 0bda684..ec6b58f 100644
--- a/loggroup-lambda-connector/sam/packaged.yaml
+++ b/loggroup-lambda-connector/sam/packaged.yaml
@@ -59,6 +59,14 @@ Parameters:
     Description: Enter comma separated keyvalue pairs for filtering logGroups using
       tags. Ex KeyName1=string,KeyName2=string. This is optional leave it blank if
       tag based filtering is not needed.
+  FilterName:
+    Type: String
+    Default: 'SumoLGLBDFilter'
+    Description: A name for the subscription filter
+  FilterPattern:
+    Type: String
+    Default: ''
+    Description: Filter pattern for subscribing to a filtered stream of log events
   RoleArn:
     Type: String
     Default: ''
diff --git a/loggroup-lambda-connector/sam/template.yaml b/loggroup-lambda-connector/sam/template.yaml
index 30a3fd8..b2b5cfb 100644
--- a/loggroup-lambda-connector/sam/template.yaml
+++ b/loggroup-lambda-connector/sam/template.yaml
@@ -60,6 +60,16 @@ Parameters:
     Default: ""
     Description: "Enter comma separated keyvalue pairs for filtering logGroups using tags. Ex KeyName1=string,KeyName2=string. This is optional leave it blank if tag based filtering is not needed."
 
+  FilterName:
+    Type: String
+    Default: "SumoLGLBDFilter"
+    Description: "A name for the subscription filter"
+
+  FilterPattern:
+    Type: String
+    Default: ""
+    Description: "Filter pattern for subscribing to a filtered stream of log events"
+
   RoleArn:
     Type: String
     Default: ""
@@ -105,6 +115,8 @@ Resources:
           DESTINATION_ARN: !Ref "DestinationArnValue"
           LOG_GROUP_PATTERN: !Ref "LogGroupPattern"
           LOG_GROUP_TAGS: !Join [ ",", { "Ref": "LogGroupTags" } ]
+          FILTER_NAME: !Ref "FilterName"
+          FILTER_PATTERN: !Ref "FilterPattern"
           ROLE_ARN: !Ref "RoleArn"
       Policies:
         - Statement:
@@ -216,6 +228,8 @@ Resources:
       ServiceToken: !GetAtt SumoLogGroupExistingLambdaConnector.Arn
       DESTINATION_ARN: !Ref "DestinationArnValue"
       LOG_GROUP_PATTERN: !Ref "LogGroupPattern"
+      FILTER_NAME: !Ref "FilterName"
+      FILTER_PATTERN: !Ref "FilterPattern"
       ROLE_ARN: !Ref "RoleArn"
 
 Outputs:
diff --git a/loggroup-lambda-connector/src/loggroup-lambda-connector.js b/loggroup-lambda-connector/src/loggroup-lambda-connector.js
index d5020fe..34eac05 100644
--- a/loggroup-lambda-connector/src/loggroup-lambda-connector.js
+++ b/loggroup-lambda-connector/src/loggroup-lambda-connector.js
@@ -77,20 +77,20 @@ function filterNewLogGroups(event, logGroupRegex) {
     return IsTagMatchToLogGroup(tagMatcherForLogGroup, logGroupTags)
 }
 
-async function createSubscriptionFilter(lambdaLogGroupName, destinationArn, roleArn, additionalArgs) {
+async function createSubscriptionFilter(lambdaLogGroupName, destinationArn, filterName, filterPattern, roleArn, additionalArgs) {
     var params={};
     if (destinationArn.startsWith("arn:aws:lambda")) {
         params = {
             destinationArn: destinationArn,
-            filterName: 'SumoLGLBDFilter',
-            filterPattern: '',
+            filterName: filterName,
+            filterPattern: filterPattern,
             logGroupName: lambdaLogGroupName
         };
     } else {
         params = {
             destinationArn: destinationArn,
-            filterName: 'SumoLGLBDFilter',
-            filterPattern: '',
+            filterName: filterName,
+            filterPattern: filterPattern
             logGroupName: lambdaLogGroupName,
             roleArn: roleArn
         };
@@ -112,6 +112,8 @@ async function subscribeExistingLogGroups(logGroups, retryCounter, additionalArg
     var logGroupRegex = validateRegex(process.env.LOG_GROUP_PATTERN);
     console.log("logGroupRegexPattern: ", logGroupRegex);
     var destinationArn = process.env.DESTINATION_ARN;
+    var filterName = process.env.FILTER_NAME
+    var filterPattern = process.env.FILTER_PATTERN
     var roleArn = process.env.ROLE_ARN;
     const failedLogGroupNames = [];
     await logGroups.reduce(async (previousPromise, nextLogGroup) => {
@@ -119,7 +121,7 @@ async function subscribeExistingLogGroups(logGroups, retryCounter, additionalArg
         const { logGroupName } = nextLogGroup;
         let filterStatus = await filterExistingLogGroups(logGroupName, logGroupRegex);
         if (filterStatus) {
-            return createSubscriptionFilter(logGroupName, destinationArn, roleArn, additionalArgs).catch(function (err) {
+            return createSubscriptionFilter(logGroupName, destinationArn, filterName, filterPattern, roleArn, additionalArgs).catch(function (err) {
                 if (err && err.message === "Rate exceeded") {
                     failedLogGroupNames.push({ logGroupName: logGroupName });
                 }
@@ -197,11 +199,13 @@ async function delay(ms) {
 async function processEvents(env, event, additionalArgs, errorHandler, retryCounter=0) {
   var logGroupName = event.detail.requestParameters.logGroupName;
   var logGroupRegex = validateRegex(env.LOG_GROUP_PATTERN);
+  var filterName = env.FILTER_NAME
+  var filterPattern = env.FILTER_PATTERN
   console.log("logGroupRegex: ", logGroupRegex);
   if (filterNewLogGroups(event, logGroupRegex)) {
     console.log("Subscribing: ", logGroupName, env.DESTINATION_ARN);
     try {
-        await createSubscriptionFilter(logGroupName, env.DESTINATION_ARN, env.ROLE_ARN, additionalArgs);
+        await createSubscriptionFilter(logGroupName, env.DESTINATION_ARN, filterName, filterPattern, env.ROLE_ARN, additionalArgs);
     } catch (err) {
       errorHandler(err, "Error in Subscribing.");
       if (err && err.message === "Rate exceeded" && retryCounter <= maxRetryCounter) {
@@ -243,4 +247,4 @@ exports.handler = async function (event, context, callback) {
     } else {
       await processEvents(process.env, event, additionalArgs, errorHandler);
     }
-};
\ No newline at end of file
+};