|
|
@@ -23,7 +23,6 @@ import java.util.concurrent.TimeUnit;
|
|
|
*
|
|
|
* @author dyp
|
|
|
*/
|
|
|
-@Slf4j
|
|
|
public class RedisService implements Serializable {
|
|
|
private int port = 6379;
|
|
|
private String password = "";
|
|
|
@@ -49,7 +48,7 @@ public class RedisService implements Serializable {
|
|
|
String redisKey = redisKey(record, config);
|
|
|
String value = JSONUtils.toJson(record);
|
|
|
if (RandomUtils.nextDouble() <= 0.001d) {
|
|
|
- log.info("redisKey: {}, value: {}", redisKey, value);
|
|
|
+ System.out.printf("redisKey: %s, value: %s%n", redisKey, value);
|
|
|
}
|
|
|
batch.put(redisKey, value);
|
|
|
if (batch.size() >= 1000) {
|
