小编Jas*_*ter的帖子

我有使用debezium更改数据捕获在mysql中捕获数据并使用kafka connect jdbc sink将其消耗给另一个mysql的问题.

因为debezium对kafka主题产生的模式和有效负载与kafka connect jdbc sink期望的模式不兼容.

当jdbc接收器想要使用数据并在另一个mysql中创建记录时,我得到异常.

我该如何解决这个问题？

我在具有相同lambda表达式的相同数组上使用了reduce with stream和parallelStream,我期望相同的结果,但输出是不同的.但是,结果不同,我不知道为什么.

代码:

    System.out.println("Reduce me...");
    Integer[] arrx = {1,2,3,4};
    //        Reducing the Array

    Arrays
            .stream(arrx)
            .reduce((s1, s2) -> (int)Math.pow(s1,2) + (int)Math.pow(s2,2))
            .ifPresent(System.out::println);

    Arrays.asList(arrx)
            .parallelStream()
            .reduce((s1, s2) -> (int)Math.pow(s1,2) + (int)Math.pow(s2,2))
            .ifPresent(System.out::println);

输出:

1172
650