mirror of
https://github.com/Snailclimb/JavaGuide
synced 2025-08-14 05:21:42 +08:00
Compare commits
4 Commits
ce28705dab
...
ad8bd31ce9
Author | SHA1 | Date | |
---|---|---|---|
|
ad8bd31ce9 | ||
|
15f51a1fa1 | ||
|
b1dfd2e40a | ||
|
4ce1395b7c |
@ -188,7 +188,7 @@ if (sendResult.getRecordMetadata() != null) {
|
||||
|
||||
解决办法就是我们设置 **acks = all**。acks 是 Kafka 生产者(Producer) 很重要的一个参数。
|
||||
|
||||
acks 的默认值即为1,代表我们的消息被leader副本接收之后就算被成功发送。当我们配置 **acks = all** 代表则所有副本都要接收到该消息之后该消息才算真正成功被发送。
|
||||
acks 的默认值即为1,代表我们的消息被leader副本接收之后就算被成功发送。当我们配置 **acks = all** 表示只有所有 ISR 列表的副本全部收到消息时,生产者才会接收到来自服务器的响应. 这种模式是最高级别的,也是最安全的,可以确保不止一个 Broker 接收到了消息. 该模式的延迟会很高.
|
||||
|
||||
**设置 replication.factor >= 3**
|
||||
|
||||
|
@ -854,8 +854,8 @@ public void afterDay(){
|
||||
Date date1 = format.parse(dates1);
|
||||
Date date2 = format.parse(dates2);
|
||||
int day = (int) ((date1.getTime() - date2.getTime()) / (1000 * 3600 * 24));
|
||||
System.out.println(dates2 + "和" + dates2 + "相差" + day + "天");
|
||||
//结果:2021-12-23和2021-12-23相差300天
|
||||
System.out.println(dates1 + "和" + dates2 + "相差" + day + "天");
|
||||
//结果:2021-02-26和2021-12-23相差300天
|
||||
}
|
||||
```
|
||||
|
||||
@ -883,8 +883,8 @@ public void pushWeek(){
|
||||
//这里period.getDays()得到的天是抛去年月以外的天数,并不是总天数
|
||||
//如果要获取纯粹的总天数应该用下面的方法
|
||||
long day = date2.toEpochDay() - date1.toEpochDay();
|
||||
System.out.println(date2 + "和" + date2 + "相差" + day + "天");
|
||||
//打印结果:2021-12-23和2021-12-23相差300天
|
||||
System.out.println(date1 + "和" + date2 + "相差" + day + "天");
|
||||
//打印结果:2021-02-26和2021-12-23相差300天
|
||||
}
|
||||
```
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user