in core/sdk/src/consumer_groups/create_consumer_group.rs [69:81]
fn validate(&self) -> Result<(), IggyError> {
if let Some(group_id) = self.group_id {
if group_id == 0 {
return Err(IggyError::InvalidConsumerGroupId);
}
}
if self.name.is_empty() || self.name.len() > MAX_NAME_LENGTH {
return Err(IggyError::InvalidConsumerGroupName);
}
Ok(())
}