franz/consumer_config
Types
pub type ConsumerConfig {
BeginOffset(OffsetTime)
MinBytes(Int)
MaxBytes(Int)
MaxWaitTime(Int)
SleepTimeout(Int)
PrefetchCount(Int)
PrefetchBytes(Int)
OffsetResetPolicy(OffsetResetPolicy)
SizeStatWindow(Int)
IsolationLevel(IsolationLevel)
ShareLeaderConn(Bool)
}Constructors
-
BeginOffset(OffsetTime) -
MinBytes(Int) -
MaxBytes(Int) -
MaxWaitTime(Int) -
SleepTimeout(Int) -
PrefetchCount(Int) -
PrefetchBytes(Int) -
OffsetResetPolicy(OffsetResetPolicy) -
SizeStatWindow(Int) -
IsolationLevel(IsolationLevel) -
ShareLeaderConn(Bool)
pub type IsolationLevel {
ReadCommitted
ReadUncommitted
}Constructors
-
ReadCommitted -
ReadUncommitted
pub type OffsetResetPolicy {
ResetBySubscriber
ResetToEarliest
ResetToLatest
}Constructors
-
ResetBySubscriber -
ResetToEarliest -
ResetToLatest
pub type OffsetTime {
Earliest
Latest
MessageTimestamp(Int)
}Constructors
-
Earliest -
Latest -
MessageTimestamp(Int)