fix remove member from group v3 message

Dushyant Bhalgami · Dushyant Bhalgami · commit 29aec38a401b · 2020-08-13T17:56:00.000+05:30
diff --git a/src/services/GroupMembershipService.js b/src/services/GroupMembershipService.js
@@ -234,8 +234,8 @@ async function deleteGroupMember(currentUser, groupId, memberId, query) {
       memberId
     }
 
-    // logger.debug(`sending message ${JSON.stringify(result)} to kafka topic ${config.KAFKA_GROUP_MEMBER_DELETE_TOPIC}`)
-    // await helper.postBusEvent(config.KAFKA_GROUP_MEMBER_DELETE_TOPIC, result)
+    logger.debug(`sending message ${JSON.stringify(result)} to kafka topic ${config.KAFKA_GROUP_MEMBER_DELETE_TOPIC}`)
+    await helper.postBusEvent(config.KAFKA_GROUP_MEMBER_DELETE_TOPIC, result)
 
     await tx.commit()
     return result

Original file line number	Diff line number	Diff line change
`@@ -234,8 +234,8 @@ async function deleteGroupMember(currentUser, groupId, memberId, query) {`
`234`	`234`	`memberId`
`235`	`235`	`}`
`236`	`236`
`237`		- // logger.debug(`sending message ${JSON.stringify(result)} to kafka topic ${config.KAFKA_GROUP_MEMBER_DELETE_TOPIC}`)
`238`		`- // await helper.postBusEvent(config.KAFKA_GROUP_MEMBER_DELETE_TOPIC, result)`
	`237`	+ logger.debug(`sending message ${JSON.stringify(result)} to kafka topic ${config.KAFKA_GROUP_MEMBER_DELETE_TOPIC}`)
	`238`	`+ await helper.postBusEvent(config.KAFKA_GROUP_MEMBER_DELETE_TOPIC, result)`
`239`	`239`
`240`	`240`	`await tx.commit()`
`241`	`241`	`return result`