#![allow(
missing_docs,
clippy::all,
clippy::pedantic,
clippy::nursery,
clippy::arithmetic_side_effects,
reason = "Generated protocol modules mirror Kafka's schema shape and intentionally trade \
hand-written lint style for reproducible wire-code output."
)]
use bytes::{Bytes, BytesMut};
use crate::*;
#[derive(Debug, Clone, PartialEq)]
pub struct FetchResponseData {
pub throttle_time_ms: i32,
pub error_code: i16,
pub session_id: i32,
pub responses: Vec<FetchableTopicResponse>,
pub node_endpoints: Vec<NodeEndpoint>,
pub _unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Default for FetchResponseData {
fn default() -> Self {
Self {
throttle_time_ms: 0_i32,
error_code: 0_i16,
session_id: 0i32,
responses: Vec::new(),
node_endpoints: Vec::new(),
_unknown_tagged_fields: Vec::new(),
}
}
}
impl FetchResponseData {
pub fn with_throttle_time_ms(mut self, value: i32) -> Self {
self.throttle_time_ms = value;
self
}
pub fn with_error_code(mut self, value: i16) -> Self {
self.error_code = value;
self
}
pub fn with_session_id(mut self, value: i32) -> Self {
self.session_id = value;
self
}
pub fn with_responses(mut self, value: Vec<FetchableTopicResponse>) -> Self {
self.responses = value;
self
}
pub fn with_node_endpoints(mut self, value: Vec<NodeEndpoint>) -> Self {
self.node_endpoints = value;
self
}
pub fn read(buf: &mut Bytes, version: i16) -> Result<Self> {
if version < 4 || version > 18 {
return Err(UnsupportedVersion::new(1, version).into());
}
let throttle_time_ms;
let mut error_code = 0_i16;
let mut session_id = 0i32;
let responses;
let mut node_endpoints = Vec::new();
let mut _unknown_tagged_fields: Vec<RawTaggedField> = Vec::new();
throttle_time_ms = read_i32(buf)?;
if version >= 7 {
error_code = read_i16(buf)?;
}
if version >= 7 {
session_id = read_i32(buf)?;
}
if version >= 12 {
responses = {
let len = read_compact_array_length(buf)?;
let mut arr = Vec::with_capacity(len.max(0) as usize);
for _ in 0..len {
arr.push(FetchableTopicResponse::read(buf, version)?);
}
arr
};
} else {
responses = {
let len = read_array_length(buf)?;
let mut arr = Vec::with_capacity(len.max(0) as usize);
for _ in 0..len {
arr.push(FetchableTopicResponse::read(buf, version)?);
}
arr
};
}
if version >= 12 {
let tagged_fields = read_tagged_fields(buf)?;
for field in &tagged_fields {
match field.tag {
0 => {
if version >= 16 {
let mut tag_buf = field.data.clone();
node_endpoints = {
let len = read_compact_array_length(&mut tag_buf)?;
let mut arr = Vec::with_capacity(len.max(0) as usize);
for _ in 0..len {
arr.push(NodeEndpoint::read(&mut tag_buf, version)?);
}
arr
};
}
},
_ => {
_unknown_tagged_fields.push(field.clone());
},
}
}
}
Ok(Self {
throttle_time_ms,
error_code,
session_id,
responses,
node_endpoints,
_unknown_tagged_fields,
})
}
pub fn write(&self, buf: &mut BytesMut, version: i16) -> Result<()> {
if version < 4 || version > 18 {
return Err(UnsupportedVersion::new(1, version).into());
}
write_i32(buf, self.throttle_time_ms);
if version >= 7 {
write_i16(buf, self.error_code);
} else if self.error_code != 0_i16 {
return Err(UnsupportedFieldVersion::new(1, "error_code", version).into());
}
if version >= 7 {
write_i32(buf, self.session_id);
} else if self.session_id != 0i32 {
return Err(UnsupportedFieldVersion::new(1, "session_id", version).into());
}
if version >= 12 {
write_compact_array_length(buf, self.responses.len() as i32);
for el in &self.responses {
el.write(buf, version)?;
}
} else {
write_array_length(buf, self.responses.len() as i32);
for el in &self.responses {
el.write(buf, version)?;
}
}
if version >= 12 {
let mut known_tagged_fields: Vec<RawTaggedField> = Vec::new();
if version >= 16 && !self.node_endpoints.is_empty() {
let mut tag_buf = BytesMut::new();
write_compact_array_length(&mut tag_buf, self.node_endpoints.len() as i32);
for el in &self.node_endpoints {
el.write(&mut tag_buf, version)?;
}
known_tagged_fields.push(RawTaggedField {
tag: 0,
data: tag_buf.freeze(),
});
}
let mut all_tags = known_tagged_fields;
all_tags.extend(self._unknown_tagged_fields.iter().cloned());
all_tags.sort_by_key(|f| f.tag);
write_tagged_fields(buf, &all_tags)?;
}
Ok(())
}
pub fn encoded_len(&self, version: i16) -> Result<usize> {
if version < 4 || version > 18 {
return Err(UnsupportedVersion::new(1, version).into());
}
let mut len: usize = 0;
len += 4;
if version >= 7 {
len += 2;
} else if self.error_code != 0_i16 {
return Err(UnsupportedFieldVersion::new(1, "error_code", version).into());
}
if version >= 7 {
len += 4;
} else if self.session_id != 0i32 {
return Err(UnsupportedFieldVersion::new(1, "session_id", version).into());
}
if version >= 12 {
len += compact_array_length_len(self.responses.len() as i32);
for el in &self.responses {
len += el.encoded_len(version)?;
}
} else {
len += array_length_len();
for el in &self.responses {
len += el.encoded_len(version)?;
}
}
if version >= 12 {
let mut known_tagged_fields: Vec<RawTaggedField> = Vec::new();
if version >= 16 && !self.node_endpoints.is_empty() {
let mut tag_buf = BytesMut::new();
write_compact_array_length(&mut tag_buf, self.node_endpoints.len() as i32);
for el in &self.node_endpoints {
el.write(&mut tag_buf, version)?;
}
known_tagged_fields.push(RawTaggedField {
tag: 0,
data: tag_buf.freeze(),
});
}
let mut all_tags = known_tagged_fields;
all_tags.extend(self._unknown_tagged_fields.iter().cloned());
all_tags.sort_by_key(|f| f.tag);
len += tagged_fields_len(&all_tags)?;
}
Ok(len)
}
}
#[derive(Debug, Clone, PartialEq)]
pub struct FetchableTopicResponse {
pub topic: KafkaString,
pub topic_id: KafkaUuid,
pub partitions: Vec<PartitionData>,
pub _unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Default for FetchableTopicResponse {
fn default() -> Self {
Self {
topic: KafkaString::default(),
topic_id: KafkaUuid::ZERO,
partitions: Vec::new(),
_unknown_tagged_fields: Vec::new(),
}
}
}
impl FetchableTopicResponse {
pub fn with_topic(mut self, value: KafkaString) -> Self {
self.topic = value;
self
}
pub fn with_topic_id(mut self, value: KafkaUuid) -> Self {
self.topic_id = value;
self
}
pub fn with_partitions(mut self, value: Vec<PartitionData>) -> Self {
self.partitions = value;
self
}
pub fn read(buf: &mut Bytes, version: i16) -> Result<Self> {
let mut topic = KafkaString::default();
let mut topic_id = KafkaUuid::ZERO;
let partitions;
let mut _unknown_tagged_fields: Vec<RawTaggedField> = Vec::new();
if version <= 12 {
if version >= 12 {
topic = read_compact_string(buf)?;
} else {
topic = read_string(buf)?;
}
}
if version >= 13 {
topic_id = read_uuid(buf)?;
}
if version >= 12 {
partitions = {
let len = read_compact_array_length(buf)?;
let mut arr = Vec::with_capacity(len.max(0) as usize);
for _ in 0..len {
arr.push(PartitionData::read(buf, version)?);
}
arr
};
} else {
partitions = {
let len = read_array_length(buf)?;
let mut arr = Vec::with_capacity(len.max(0) as usize);
for _ in 0..len {
arr.push(PartitionData::read(buf, version)?);
}
arr
};
}
if version >= 12 {
let tagged_fields = read_tagged_fields(buf)?;
for field in &tagged_fields {
match field.tag {
_ => {
_unknown_tagged_fields.push(field.clone());
},
}
}
}
Ok(Self {
topic,
topic_id,
partitions,
_unknown_tagged_fields,
})
}
pub fn write(&self, buf: &mut BytesMut, version: i16) -> Result<()> {
if version <= 12 {
if version >= 12 {
write_compact_string(buf, &self.topic)?;
} else {
write_string(buf, &self.topic)?;
}
} else if self.topic != KafkaString::default() {
return Err(UnsupportedFieldVersion::new(1, "topic", version).into());
}
if version >= 13 {
write_uuid(buf, &self.topic_id);
} else if self.topic_id != KafkaUuid::ZERO {
return Err(UnsupportedFieldVersion::new(1, "topic_id", version).into());
}
if version >= 12 {
write_compact_array_length(buf, self.partitions.len() as i32);
for el in &self.partitions {
el.write(buf, version)?;
}
} else {
write_array_length(buf, self.partitions.len() as i32);
for el in &self.partitions {
el.write(buf, version)?;
}
}
if version >= 12 {
let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
all_tags.sort_by_key(|f| f.tag);
write_tagged_fields(buf, &all_tags)?;
}
Ok(())
}
pub fn encoded_len(&self, version: i16) -> Result<usize> {
let mut len: usize = 0;
if version <= 12 {
if version >= 12 {
len += compact_string_len(&self.topic)?;
} else {
len += string_len(&self.topic)?;
}
} else if self.topic != KafkaString::default() {
return Err(UnsupportedFieldVersion::new(1, "topic", version).into());
}
if version >= 13 {
len += 16;
} else if self.topic_id != KafkaUuid::ZERO {
return Err(UnsupportedFieldVersion::new(1, "topic_id", version).into());
}
if version >= 12 {
len += compact_array_length_len(self.partitions.len() as i32);
for el in &self.partitions {
len += el.encoded_len(version)?;
}
} else {
len += array_length_len();
for el in &self.partitions {
len += el.encoded_len(version)?;
}
}
if version >= 12 {
let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
all_tags.sort_by_key(|f| f.tag);
len += tagged_fields_len(&all_tags)?;
}
Ok(len)
}
}
#[derive(Debug, Clone, PartialEq)]
pub struct PartitionData {
pub partition_index: i32,
pub error_code: i16,
pub high_watermark: i64,
pub last_stable_offset: i64,
pub log_start_offset: i64,
pub diverging_epoch: EpochEndOffset,
pub current_leader: LeaderIdAndEpoch,
pub snapshot_id: SnapshotId,
pub aborted_transactions: Option<Vec<AbortedTransaction>>,
pub preferred_read_replica: i32,
pub records: Option<Bytes>,
pub _unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Default for PartitionData {
fn default() -> Self {
Self {
partition_index: 0_i32,
error_code: 0_i16,
high_watermark: 0_i64,
last_stable_offset: -1i64,
log_start_offset: -1i64,
diverging_epoch: EpochEndOffset::default(),
current_leader: LeaderIdAndEpoch::default(),
snapshot_id: SnapshotId::default(),
aborted_transactions: None,
preferred_read_replica: -1i32,
records: None,
_unknown_tagged_fields: Vec::new(),
}
}
}
impl PartitionData {
pub fn with_partition_index(mut self, value: i32) -> Self {
self.partition_index = value;
self
}
pub fn with_error_code(mut self, value: i16) -> Self {
self.error_code = value;
self
}
pub fn with_high_watermark(mut self, value: i64) -> Self {
self.high_watermark = value;
self
}
pub fn with_last_stable_offset(mut self, value: i64) -> Self {
self.last_stable_offset = value;
self
}
pub fn with_log_start_offset(mut self, value: i64) -> Self {
self.log_start_offset = value;
self
}
pub fn with_diverging_epoch(mut self, value: EpochEndOffset) -> Self {
self.diverging_epoch = value;
self
}
pub fn with_current_leader(mut self, value: LeaderIdAndEpoch) -> Self {
self.current_leader = value;
self
}
pub fn with_snapshot_id(mut self, value: SnapshotId) -> Self {
self.snapshot_id = value;
self
}
pub fn with_aborted_transactions(mut self, value: Option<Vec<AbortedTransaction>>) -> Self {
self.aborted_transactions = value;
self
}
pub fn with_preferred_read_replica(mut self, value: i32) -> Self {
self.preferred_read_replica = value;
self
}
pub fn with_records(mut self, value: Option<Bytes>) -> Self {
self.records = value;
self
}
pub fn read(buf: &mut Bytes, version: i16) -> Result<Self> {
let partition_index;
let error_code;
let high_watermark;
let last_stable_offset;
let mut log_start_offset = -1i64;
let mut diverging_epoch = EpochEndOffset::default();
let mut current_leader = LeaderIdAndEpoch::default();
let mut snapshot_id = SnapshotId::default();
let aborted_transactions;
let mut preferred_read_replica = -1i32;
let records;
let mut _unknown_tagged_fields: Vec<RawTaggedField> = Vec::new();
partition_index = read_i32(buf)?;
error_code = read_i16(buf)?;
high_watermark = read_i64(buf)?;
last_stable_offset = read_i64(buf)?;
if version >= 5 {
log_start_offset = read_i64(buf)?;
}
if version >= 12 {
aborted_transactions = {
let len = read_compact_array_length(buf)?;
if len < 0 {
None
} else {
let mut arr = Vec::with_capacity(len as usize);
for _ in 0..len {
arr.push(AbortedTransaction::read(buf, version)?);
}
Some(arr)
}
};
} else {
aborted_transactions = {
let len = read_array_length(buf)?;
if len < 0 {
None
} else {
let mut arr = Vec::with_capacity(len as usize);
for _ in 0..len {
arr.push(AbortedTransaction::read(buf, version)?);
}
Some(arr)
}
};
}
if version >= 11 {
preferred_read_replica = read_i32(buf)?;
}
if version >= 12 {
records = read_compact_nullable_bytes(buf)?;
} else {
records = read_nullable_bytes(buf)?;
}
if version >= 12 {
let tagged_fields = read_tagged_fields(buf)?;
for field in &tagged_fields {
match field.tag {
0 => {
let mut tag_buf = field.data.clone();
diverging_epoch = EpochEndOffset::read(&mut tag_buf, version)?;
},
1 => {
let mut tag_buf = field.data.clone();
current_leader = LeaderIdAndEpoch::read(&mut tag_buf, version)?;
},
2 => {
let mut tag_buf = field.data.clone();
snapshot_id = SnapshotId::read(&mut tag_buf, version)?;
},
_ => {
_unknown_tagged_fields.push(field.clone());
},
}
}
}
Ok(Self {
partition_index,
error_code,
high_watermark,
last_stable_offset,
log_start_offset,
diverging_epoch,
current_leader,
snapshot_id,
aborted_transactions,
preferred_read_replica,
records,
_unknown_tagged_fields,
})
}
pub fn write(&self, buf: &mut BytesMut, version: i16) -> Result<()> {
write_i32(buf, self.partition_index);
write_i16(buf, self.error_code);
write_i64(buf, self.high_watermark);
write_i64(buf, self.last_stable_offset);
if version >= 5 {
write_i64(buf, self.log_start_offset);
} else if self.log_start_offset != -1i64 {
return Err(UnsupportedFieldVersion::new(1, "log_start_offset", version).into());
}
if version >= 12 {
match &self.aborted_transactions {
None => {
write_compact_array_length(buf, -1);
},
Some(arr) => {
write_compact_array_length(buf, arr.len() as i32);
for el in arr {
el.write(buf, version)?;
}
},
}
} else {
match &self.aborted_transactions {
None => {
write_array_length(buf, -1);
},
Some(arr) => {
write_array_length(buf, arr.len() as i32);
for el in arr {
el.write(buf, version)?;
}
},
}
}
if version >= 11 {
write_i32(buf, self.preferred_read_replica);
} else if self.preferred_read_replica != -1i32 {
return Err(UnsupportedFieldVersion::new(1, "preferred_read_replica", version).into());
}
if version >= 12 {
write_compact_nullable_bytes(buf, self.records.as_ref().map(|b| b.as_ref()))?;
} else {
write_nullable_bytes(buf, self.records.as_ref().map(|b| b.as_ref()))?;
}
if version >= 12 {
let mut known_tagged_fields: Vec<RawTaggedField> = Vec::new();
if self.diverging_epoch != EpochEndOffset::default() {
let mut tag_buf = BytesMut::new();
self.diverging_epoch.write(&mut tag_buf, version)?;
known_tagged_fields.push(RawTaggedField {
tag: 0,
data: tag_buf.freeze(),
});
}
if self.current_leader != LeaderIdAndEpoch::default() {
let mut tag_buf = BytesMut::new();
self.current_leader.write(&mut tag_buf, version)?;
known_tagged_fields.push(RawTaggedField {
tag: 1,
data: tag_buf.freeze(),
});
}
if self.snapshot_id != SnapshotId::default() {
let mut tag_buf = BytesMut::new();
self.snapshot_id.write(&mut tag_buf, version)?;
known_tagged_fields.push(RawTaggedField {
tag: 2,
data: tag_buf.freeze(),
});
}
let mut all_tags = known_tagged_fields;
all_tags.extend(self._unknown_tagged_fields.iter().cloned());
all_tags.sort_by_key(|f| f.tag);
write_tagged_fields(buf, &all_tags)?;
}
Ok(())
}
pub fn encoded_len(&self, version: i16) -> Result<usize> {
let mut len: usize = 0;
len += 4;
len += 2;
len += 8;
len += 8;
if version >= 5 {
len += 8;
} else if self.log_start_offset != -1i64 {
return Err(UnsupportedFieldVersion::new(1, "log_start_offset", version).into());
}
if version >= 12 {
match &self.aborted_transactions {
None => {
len += compact_array_length_len(-1);
},
Some(arr) => {
len += compact_array_length_len(arr.len() as i32);
for el in arr {
len += el.encoded_len(version)?;
}
},
}
} else {
match &self.aborted_transactions {
None => {
len += array_length_len();
},
Some(arr) => {
len += array_length_len();
for el in arr {
len += el.encoded_len(version)?;
}
},
}
}
if version >= 11 {
len += 4;
} else if self.preferred_read_replica != -1i32 {
return Err(UnsupportedFieldVersion::new(1, "preferred_read_replica", version).into());
}
if version >= 12 {
len += compact_nullable_bytes_len(self.records.as_ref().map(|b| b.as_ref()))?;
} else {
len += nullable_bytes_len(self.records.as_ref().map(|b| b.as_ref()))?;
}
if version >= 12 {
let mut known_tagged_fields: Vec<RawTaggedField> = Vec::new();
if self.diverging_epoch != EpochEndOffset::default() {
let mut tag_buf = BytesMut::new();
self.diverging_epoch.write(&mut tag_buf, version)?;
known_tagged_fields.push(RawTaggedField {
tag: 0,
data: tag_buf.freeze(),
});
}
if self.current_leader != LeaderIdAndEpoch::default() {
let mut tag_buf = BytesMut::new();
self.current_leader.write(&mut tag_buf, version)?;
known_tagged_fields.push(RawTaggedField {
tag: 1,
data: tag_buf.freeze(),
});
}
if self.snapshot_id != SnapshotId::default() {
let mut tag_buf = BytesMut::new();
self.snapshot_id.write(&mut tag_buf, version)?;
known_tagged_fields.push(RawTaggedField {
tag: 2,
data: tag_buf.freeze(),
});
}
let mut all_tags = known_tagged_fields;
all_tags.extend(self._unknown_tagged_fields.iter().cloned());
all_tags.sort_by_key(|f| f.tag);
len += tagged_fields_len(&all_tags)?;
}
Ok(len)
}
}
#[derive(Debug, Clone, PartialEq)]
pub struct EpochEndOffset {
pub epoch: i32,
pub end_offset: i64,
pub _unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Default for EpochEndOffset {
fn default() -> Self {
Self {
epoch: -1i32,
end_offset: -1i64,
_unknown_tagged_fields: Vec::new(),
}
}
}
impl EpochEndOffset {
pub fn with_epoch(mut self, value: i32) -> Self {
self.epoch = value;
self
}
pub fn with_end_offset(mut self, value: i64) -> Self {
self.end_offset = value;
self
}
pub fn read(buf: &mut Bytes, _version: i16) -> Result<Self> {
let epoch;
let end_offset;
let mut _unknown_tagged_fields: Vec<RawTaggedField> = Vec::new();
epoch = read_i32(buf)?;
end_offset = read_i64(buf)?;
let tagged_fields = read_tagged_fields(buf)?;
for field in &tagged_fields {
match field.tag {
_ => {
_unknown_tagged_fields.push(field.clone());
},
}
}
Ok(Self {
epoch,
end_offset,
_unknown_tagged_fields,
})
}
pub fn write(&self, buf: &mut BytesMut, _version: i16) -> Result<()> {
write_i32(buf, self.epoch);
write_i64(buf, self.end_offset);
let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
all_tags.sort_by_key(|f| f.tag);
write_tagged_fields(buf, &all_tags)?;
Ok(())
}
pub fn encoded_len(&self, _version: i16) -> Result<usize> {
let mut len: usize = 0;
len += 4;
len += 8;
let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
all_tags.sort_by_key(|f| f.tag);
len += tagged_fields_len(&all_tags)?;
Ok(len)
}
}
#[derive(Debug, Clone, PartialEq)]
pub struct LeaderIdAndEpoch {
pub leader_id: i32,
pub leader_epoch: i32,
pub _unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Default for LeaderIdAndEpoch {
fn default() -> Self {
Self {
leader_id: -1i32,
leader_epoch: -1i32,
_unknown_tagged_fields: Vec::new(),
}
}
}
impl LeaderIdAndEpoch {
pub fn with_leader_id(mut self, value: i32) -> Self {
self.leader_id = value;
self
}
pub fn with_leader_epoch(mut self, value: i32) -> Self {
self.leader_epoch = value;
self
}
pub fn read(buf: &mut Bytes, _version: i16) -> Result<Self> {
let leader_id;
let leader_epoch;
let mut _unknown_tagged_fields: Vec<RawTaggedField> = Vec::new();
leader_id = read_i32(buf)?;
leader_epoch = read_i32(buf)?;
let tagged_fields = read_tagged_fields(buf)?;
for field in &tagged_fields {
match field.tag {
_ => {
_unknown_tagged_fields.push(field.clone());
},
}
}
Ok(Self {
leader_id,
leader_epoch,
_unknown_tagged_fields,
})
}
pub fn write(&self, buf: &mut BytesMut, _version: i16) -> Result<()> {
write_i32(buf, self.leader_id);
write_i32(buf, self.leader_epoch);
let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
all_tags.sort_by_key(|f| f.tag);
write_tagged_fields(buf, &all_tags)?;
Ok(())
}
pub fn encoded_len(&self, _version: i16) -> Result<usize> {
let mut len: usize = 0;
len += 4;
len += 4;
let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
all_tags.sort_by_key(|f| f.tag);
len += tagged_fields_len(&all_tags)?;
Ok(len)
}
}
#[derive(Debug, Clone, PartialEq)]
pub struct SnapshotId {
pub end_offset: i64,
pub epoch: i32,
pub _unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Default for SnapshotId {
fn default() -> Self {
Self {
end_offset: -1i64,
epoch: -1i32,
_unknown_tagged_fields: Vec::new(),
}
}
}
impl SnapshotId {
pub fn with_end_offset(mut self, value: i64) -> Self {
self.end_offset = value;
self
}
pub fn with_epoch(mut self, value: i32) -> Self {
self.epoch = value;
self
}
pub fn read(buf: &mut Bytes, _version: i16) -> Result<Self> {
let end_offset;
let epoch;
let mut _unknown_tagged_fields: Vec<RawTaggedField> = Vec::new();
end_offset = read_i64(buf)?;
epoch = read_i32(buf)?;
let tagged_fields = read_tagged_fields(buf)?;
for field in &tagged_fields {
match field.tag {
_ => {
_unknown_tagged_fields.push(field.clone());
},
}
}
Ok(Self {
end_offset,
epoch,
_unknown_tagged_fields,
})
}
pub fn write(&self, buf: &mut BytesMut, _version: i16) -> Result<()> {
write_i64(buf, self.end_offset);
write_i32(buf, self.epoch);
let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
all_tags.sort_by_key(|f| f.tag);
write_tagged_fields(buf, &all_tags)?;
Ok(())
}
pub fn encoded_len(&self, _version: i16) -> Result<usize> {
let mut len: usize = 0;
len += 8;
len += 4;
let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
all_tags.sort_by_key(|f| f.tag);
len += tagged_fields_len(&all_tags)?;
Ok(len)
}
}
#[derive(Debug, Clone, PartialEq)]
pub struct AbortedTransaction {
pub producer_id: i64,
pub first_offset: i64,
pub _unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Default for AbortedTransaction {
fn default() -> Self {
Self {
producer_id: 0_i64,
first_offset: 0_i64,
_unknown_tagged_fields: Vec::new(),
}
}
}
impl AbortedTransaction {
pub fn with_producer_id(mut self, value: i64) -> Self {
self.producer_id = value;
self
}
pub fn with_first_offset(mut self, value: i64) -> Self {
self.first_offset = value;
self
}
pub fn read(buf: &mut Bytes, version: i16) -> Result<Self> {
let producer_id;
let first_offset;
let mut _unknown_tagged_fields: Vec<RawTaggedField> = Vec::new();
producer_id = read_i64(buf)?;
first_offset = read_i64(buf)?;
if version >= 12 {
let tagged_fields = read_tagged_fields(buf)?;
for field in &tagged_fields {
match field.tag {
_ => {
_unknown_tagged_fields.push(field.clone());
},
}
}
}
Ok(Self {
producer_id,
first_offset,
_unknown_tagged_fields,
})
}
pub fn write(&self, buf: &mut BytesMut, version: i16) -> Result<()> {
write_i64(buf, self.producer_id);
write_i64(buf, self.first_offset);
if version >= 12 {
let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
all_tags.sort_by_key(|f| f.tag);
write_tagged_fields(buf, &all_tags)?;
}
Ok(())
}
pub fn encoded_len(&self, version: i16) -> Result<usize> {
let mut len: usize = 0;
len += 8;
len += 8;
if version >= 12 {
let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
all_tags.sort_by_key(|f| f.tag);
len += tagged_fields_len(&all_tags)?;
}
Ok(len)
}
}
#[derive(Debug, Clone, PartialEq)]
pub struct NodeEndpoint {
pub node_id: i32,
pub host: KafkaString,
pub port: i32,
pub rack: Option<KafkaString>,
pub _unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Default for NodeEndpoint {
fn default() -> Self {
Self {
node_id: 0_i32,
host: KafkaString::default(),
port: 0_i32,
rack: None,
_unknown_tagged_fields: Vec::new(),
}
}
}
impl NodeEndpoint {
pub fn with_node_id(mut self, value: i32) -> Self {
self.node_id = value;
self
}
pub fn with_host(mut self, value: KafkaString) -> Self {
self.host = value;
self
}
pub fn with_port(mut self, value: i32) -> Self {
self.port = value;
self
}
pub fn with_rack(mut self, value: Option<KafkaString>) -> Self {
self.rack = value;
self
}
pub fn read(buf: &mut Bytes, _version: i16) -> Result<Self> {
let node_id;
let host;
let port;
let rack;
let mut _unknown_tagged_fields: Vec<RawTaggedField> = Vec::new();
node_id = read_i32(buf)?;
host = read_compact_string(buf)?;
port = read_i32(buf)?;
rack = read_compact_nullable_string(buf)?;
let tagged_fields = read_tagged_fields(buf)?;
for field in &tagged_fields {
match field.tag {
_ => {
_unknown_tagged_fields.push(field.clone());
},
}
}
Ok(Self {
node_id,
host,
port,
rack,
_unknown_tagged_fields,
})
}
pub fn write(&self, buf: &mut BytesMut, _version: i16) -> Result<()> {
write_i32(buf, self.node_id);
write_compact_string(buf, &self.host)?;
write_i32(buf, self.port);
write_compact_nullable_string(buf, self.rack.as_ref())?;
let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
all_tags.sort_by_key(|f| f.tag);
write_tagged_fields(buf, &all_tags)?;
Ok(())
}
pub fn encoded_len(&self, _version: i16) -> Result<usize> {
let mut len: usize = 0;
len += 4;
len += compact_string_len(&self.host)?;
len += 4;
len += compact_nullable_string_len(self.rack.as_ref())?;
let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
all_tags.sort_by_key(|f| f.tag);
len += tagged_fields_len(&all_tags)?;
Ok(len)
}
}