diff --git a/src/protocol/sync_group/request.rs b/src/protocol/sync_group/request.rs index 4fb26a6..46f2828 100644 --- a/src/protocol/sync_group/request.rs +++ b/src/protocol/sync_group/request.rs @@ -110,8 +110,8 @@ impl Assignment<'_> { } } -impl PartitionAssignment<'_> { - pub fn new(topic_name: &str, partitions: Vec) -> PartitionAssignment { +impl<'a> PartitionAssignment<'a> { + pub fn new(topic_name: &'a str, partitions: Vec) -> Self { PartitionAssignment { topic_name, partitions, @@ -119,6 +119,7 @@ impl PartitionAssignment<'_> { } } + impl<'a> SyncGroupRequest<'a> { pub fn new( correlation_id: i32,