目標Kafka高級配置
更新時間 2025-01-13 18:08:11
最近更新時間: 2025-01-13 18:08:11
分享文章
本節為您介紹數據庫遷移工具目標庫高級配置。
batch.size
用于指定緩沖區一批數據最大值
linger.ms
指定如果數據遲遲未達到 batch.size,等待linger.time之后就會發送數據
buffer.memory
RecordAccumulator 緩沖區總大小
acks
0:生產者發送過來的數據,不需要等數據落盤應答
1:生產者發送過來的數據,Leader收到數據后應答
-1(all):生產者發送過來的數據,Leader+和 isr 隊列里面的所有節點收齊數據后應答
max.in.flight.requests.per.connection
允許最多沒有返回 ack 的次數,默認為 5,開啟冪等性要保證該值是 1-5 的數字
retry.backoff.ms
當消息發送出現錯誤的時候,系統會重發消息的重試次數
compression.type
生產者發送的所有數據的壓縮方式
partition
指定kafka分區