kafka参数调优

消费者参数

        prop.put("enable.auto.commit", submit);//是否自动提交偏移量
        prop.put("max.poll.records", 100);//一批最多拉取100条
        prop.put("auto.offset.reset", "earliest");//接着上一次消费的偏移量处消费

生产者参数

        prop.put("buffer.memory", Config.bufferMemory);//配置Producer端用于缓存消息的缓冲区大小,由专属线程负责从缓冲区读取消息进行真正的发送
        prop.put("batch.size", Config.batchSize);//producer发送数据的批量磁盘空间值
        prop.put("linger.ms", Config.lingerMs);//批量发送最大停留时间