小编gok*_*ari的帖子

为什么Integer "="运算符不适用于128和Integer值之后？有人可以解释这种情况吗？

这是我的Java环境:java版"1.6.0_37"

Java(TM)SE运行时环境(版本1.6.0_37-b06)

Java HotSpot(TM)64位服务器VM(内置20.12-b01,混合模式)

示例代码:

    Integer a;
    Integer b;
    a = 129;
    b = 129;

    for (int i = 0; i < 200; i++) {
        a = i;
        b = i;

        if (a != b) {
            System.out.println("Value:"+ i + " - Different values");
        } else {
            System.out.println("Value"+ i + " Same values");
        }
    }

控制台输出的一部分:

Value:124 - Same values
Value:125 - Same values
Value:126 - Same values
Value:127 - Same values
Value:128 - Different values
Value:129 …

我们知道java.util.Date的getTime方法返回自此Date对象表示的1970年1月1日00:00:00 GMT以来的毫秒数.

我注意到一个奇怪的情况如下;

系统时区为:(UTC + 02:00)伊斯坦布尔

Date currentDate = new Date();
System.out.println(currentDate .getTime());
System.out.println(currentDate);

Java ConsoleOutput:

1360753217219

2月13日星期三13:00:17 VET 2013

然后我的javascript插件使用如下的长对象;

使用Javascript:

console.log(new Date(1360753217219));

浏览器控制台输出:

日期{Wed Feb 13 2013 13:00:17 GMT + 0200(土耳其标准时间)}

但是,一切都好!将当地时区更改为(UTC-04:30)加拉加斯后,情况和小时的变化如下,并以相同的毫秒数变化;

使用Javascript:

console.log(new Date(1360753217219));

浏览器控制台输出:

日期{Wed Feb 13 2013 06:30:17 GMT-0430(委内瑞拉标准时间)}

有人可以解释一下吗？这是js的bug吗？或者更重要的是,我应该如何在java方面处理这个问题,以便在js端为不同的时区获得相同的毫秒数？

谢谢!

当我未设置processing.gurantee时，这意味着流将以其默认值（at_least_once）启动，此代码可以成功记录并向相关主题发送加入的消息。

如果在同一流应用程序上启用了fully_once配置，则某些数据将无法成功通过联接。即使有第一个peek块的日志，我也看不到一些第二个peek日志和一些我需要的消息。

final KStream<String, UserProfile> userProfileStream = builder.stream(TOPIC_USER_PROFILE);
final KTable<String, Device> deviceKTable = builder.table(TOPIC_DEVICE);

userProfileStream
.peek((genericId, userProfile) ->
    log.debug("[{}] Processing user profile: {}", openUserId, userProfile)
)
.join(
    deviceKTable,
    (userProfile, device) -> {
        userProfile.setDevice(device);

        return userProfile;
    },
    Joined.with(Serdes.String(), userProfileSerde, deviceSerde)
) …