in rocketmq/client.py [0:0]
def set_group(self, group_name): ffi_check(dll.SetProducerGroupName(self._handle, _to_bytes(group_name)))