java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577
-
Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic set to 
问题：Caused by: java.lang.RuntimeException: Record has Long.MIN_VALUE timestamp (= no times…