Kafka消費者-重要參數


1.fetch.min.bytes

consumer一次拉取中拉取的最小數據量,默認值為1B

2.fetch.max.bytes

consumer一次拉取中拉取的最大數據量,默認值為52428800B,即50MB

3.fetch.max.wait.ms

指定Kafka的等待時間,默認值為500ms,如果消息不夠多滿足不了最小的拉取量,則等待該時間

4.max.partition.fetch.bytes

配置從每個分區里返回給consumer的最大數據量

5.max.poll.records

配置consumer在一次拉取請求中拉取的最大消息數,默認為500條

6.connections.max.idle.ms

空連接超時限制

7.exclude.internal.topics

指定Kafka中的內部主題是否可以向消費者公開,默認為true,為true則只能使用subscribe(Collection)的方式而不能使用subscribe(Pattern)的方式來訂閱內部主題

8.receive.buffer.bytes

設置socket接收消息緩沖區大小,默認值為65536B,即64KB

9.send.buffer.bytes

設置socket發送消息緩沖區大小,默認值為131072B,即128KB

10.request.timeout.ms

consumer等待請求響應的最長時間,默認為30000ms

11.metadata.max.age.ms

元數據過期時間,默認300000ms,即5分鍾,如果元數據在該時間內沒更新則強制更新

12.reconnect.backoff.ms

嘗試重新連接主機之前等待時間,默認50ms,避免頻繁連接

13.retry.backoff.ms

嘗試重新發送失敗的請求到指定主題分區之前的等待時間,默認100ms

14.isolation.level

事務隔離級別,有“read_uncommitted”和“read_committed”兩種,默認情況為read_uncommitted,可以消費到HW處的位置


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM