Struct TaskWorkerConfig 

pub struct TaskWorkerConfig {
    pub brokers: String,
    pub group_id: String,
    pub scan_interval_secs: u64,
    pub max_batch_size: usize,
    pub max_message_age_secs: u64,
    pub auto_create_topics: bool,
    pub topic_partitions: i32,
    pub topic_replication: i16,
}

TaskWorker 运行时配置（可从配置文件 [task] section 反序列化）

Fields

brokers: String

Kafka broker 地址

group_id: String

消费组 ID

scan_interval_secs: u64

重试扫描间隔（秒）

max_batch_size: usize

每批次扫描最大任务数

max_message_age_secs: u64

消息最大时效（秒），超过此时间的消息将被跳过

auto_create_topics: bool

是否在启动时自动创建 topic

topic_partitions: i32

topic 分区数（auto_create_topics 时使用）

topic_replication: i16

topic 副本数（auto_create_topics 时使用）

Trait Implementations

impl Clone for TaskWorkerConfig

fn clone(&self) -> TaskWorkerConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TaskWorkerConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TaskWorkerConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for TaskWorkerConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.