1
0
mirror of https://github.com/Snailclimb/JavaGuide synced 2025-08-14 05:21:42 +08:00

Compare commits

..

No commits in common. "ad8bd31ce9760b405fea53e73303fc2b1fc7cc66" and "ce28705dabdc9b379412174aa93f3ab4dfe7ac2f" have entirely different histories.

2 changed files with 5 additions and 5 deletions

View File

@ -188,7 +188,7 @@ if (sendResult.getRecordMetadata() != null) {
解决办法就是我们设置 **acks = all**。acks 是 Kafka 生产者(Producer) 很重要的一个参数。 解决办法就是我们设置 **acks = all**。acks 是 Kafka 生产者(Producer) 很重要的一个参数。
acks 的默认值即为1代表我们的消息被leader副本接收之后就算被成功发送。当我们配置 **acks = all** 表示只有所有 ISR 列表的副本全部收到消息时,生产者才会接收到来自服务器的响应. 这种模式是最高级别的,也是最安全的,可以确保不止一个 Broker 接收到了消息. 该模式的延迟会很高. acks 的默认值即为1代表我们的消息被leader副本接收之后就算被成功发送。当我们配置 **acks = all** 代表则所有副本都要接收到该消息之后该消息才算真正成功被发送。
**设置 replication.factor >= 3** **设置 replication.factor >= 3**

View File

@ -854,8 +854,8 @@ public void afterDay(){
Date date1 = format.parse(dates1); Date date1 = format.parse(dates1);
Date date2 = format.parse(dates2); Date date2 = format.parse(dates2);
int day = (int) ((date1.getTime() - date2.getTime()) / (1000 * 3600 * 24)); int day = (int) ((date1.getTime() - date2.getTime()) / (1000 * 3600 * 24));
System.out.println(dates1 + "和" + dates2 + "相差" + day + "天"); System.out.println(dates2 + "和" + dates2 + "相差" + day + "天");
//结果2021-02-26和2021-12-23相差300天 //结果2021-12-23和2021-12-23相差300天
} }
``` ```
@ -883,8 +883,8 @@ public void pushWeek(){
//这里period.getDays()得到的天是抛去年月以外的天数,并不是总天数 //这里period.getDays()得到的天是抛去年月以外的天数,并不是总天数
//如果要获取纯粹的总天数应该用下面的方法 //如果要获取纯粹的总天数应该用下面的方法
long day = date2.toEpochDay() - date1.toEpochDay(); long day = date2.toEpochDay() - date1.toEpochDay();
System.out.println(date1 + "和" + date2 + "相差" + day + "天"); System.out.println(date2 + "和" + date2 + "相差" + day + "天");
//打印结果2021-02-26和2021-12-23相差300天 //打印结果2021-12-23和2021-12-23相差300天
} }
``` ```