public static long generateConsumerGroupId ( String flowId , String flowletId ) { return Hashing . md5 ( ) . newHasher ( ) . putString ( flowId ) . putString ( flowletId ) . hash ( ) . asLong ( ) ; }
Generates a queue consumer groupId for the given flowlet in the given program id .