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處的位置