|
|
@@ -58,7 +58,7 @@ public class ConsumerConfig {
|
|
|
//单个分区获取消息的最大值为900M
|
|
|
props.put(org.apache.kafka.clients.consumer.ConsumerConfig.MAX_PARTITION_FETCH_BYTES_CONFIG, 943718400);
|
|
|
//一次最大拉取的条数
|
|
|
- props.put(org.apache.kafka.clients.consumer.ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 100);
|
|
|
+ props.put(org.apache.kafka.clients.consumer.ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 500);
|
|
|
props.put(org.apache.kafka.clients.consumer.ConsumerConfig.FETCH_MAX_BYTES_CONFIG, 1073741824);
|
|
|
//earliest当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，从头开始消费
|
|
|
//latest当各分区下有已提交的offset时，从提交的offset开始消费；无提交的offset时，消费新产生的该分区下的数据
|
pans