我们已经为JDBC接收器连接器启用了死信队列。我们的默认保留策略是7天,但对于DLQ,我们希望将其减少到1天。以下是我们的Sink连接器中DLQ的属性。
'errors.tolerance'='all',
'errors.deadletterqueue.topic.name' = 'error_topic',
'errors.deadletterqueue.topic.replication.factor'= -1,
'errors.log.include.messages' = true,
'errors.log.enable' = true,
'errors.deadletterqueue.context.headers.enable' = true
是否有一个属性可以用来改变保留时间?我们已经尝试使用以下属性,但没有像预期的那样工作。
'topic.creation.default.retention.ms'='3000',
'admin.topic.creation.default.retention.ms'='3000',
'admin.retention.ms' = '3000',
'admin.topic.retention.ms' = '3000',
'admin.topic.creation.retention.ms' = '3000',
'error.topic.creation.default.retention.ms'='3000',
'error.deadletterqueue.topic.creation.default.retention.ms'='3000',
'admin.topic.creation.default.retention.ms' = 3000,
提前用你需要的属性创建DLQ主题。否则,您将需要使用kafka-topics --alter
命令,因为在Connect中修改任何配置只适用于全新的主题,如果您可以在分区和复制之外设置主题配置