Apply feedback

aws · Mar 16, 2021 · 6f451cf · 6f451cf
1 parent a177e0d
commit 6f451cf
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/packages/@aws-cdk/aws-lambda-event-sources/lib/kafka.ts b/packages/@aws-cdk/aws-lambda-event-sources/lib/kafka.ts
@@ -161,7 +161,9 @@ export class SelfManagedKafkaEventSource extends StreamEventSource {
   }
 
   private mappingId(target: lambda.IFunction) {
-    const idHash = crypto.createHash('md5').update(JSON.stringify(Stack.of(target).resolve(this.innerProps.bootstrapServers))).digest('hex');
+    let hash = crypto.createHash('md5');
+    hash.update(JSON.stringify(Stack.of(target).resolve(this.innerProps.bootstrapServers)));
+    const idHash = hash.digest('hex');
     return `KafkaEventSource:${idHash}:${this.innerProps.topic}`;
   }