pub struct ProduceResponsePartitionResponse {
pub index: Int32,
pub error: Option<Error>,
pub base_offset: Int64,
pub log_append_time_ms: Option<Int64>,
pub log_start_offset: Option<Int64>,
}Fields§
§index: Int32The partition index.
error: Option<Error>Error code.
base_offset: Int64The base offset.
log_append_time_ms: Option<Int64>The timestamp returned by broker after appending the messages.
If CreateTime is used for the topic, the timestamp will be -1. If LogAppendTime is used for the topic, the timestamp will be the broker local time when the messages are appended.
Added in version 2.
log_start_offset: Option<Int64>The log start offset.
Added in version 5.
Trait Implementations§
Source§impl<R> ReadVersionedType<R> for ProduceResponsePartitionResponsewhere
R: Read,
impl<R> ReadVersionedType<R> for ProduceResponsePartitionResponsewhere
R: Read,
fn read_versioned( reader: &mut R, version: ApiVersion, ) -> Result<Self, ReadVersionedError>
Auto Trait Implementations§
impl Freeze for ProduceResponsePartitionResponse
impl RefUnwindSafe for ProduceResponsePartitionResponse
impl Send for ProduceResponsePartitionResponse
impl Sync for ProduceResponsePartitionResponse
impl Unpin for ProduceResponsePartitionResponse
impl UnwindSafe for ProduceResponsePartitionResponse
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more