性能优化

// 批量发送
props.put("batch.size", 16384);
props.put("linger.ms", 10);

// 压缩
props.put("compression.type", "snappy");