??????flink????kafka????????

Yichao Yang Mon, 29 Jun 2020 04:51:03 -0700

Hi


?????????? dercd_seeme-3 partition 
????????????????????????kafka????partition????????????


Best,
Yichao Yang




------------------&nbsp;????????&nbsp;------------------
??????:&nbsp;"??????"<[email protected]&gt;;
????????:&nbsp;2020??6??29??(??????) ????10:36
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;flink????kafka????????



Caused by: java.lang.Exception: 
org.apache.kafka.common.errors.TimeoutException: Timeout of 60000ms expired 
before the position for partition dercd_seeme-3 could be determined&nbsp; 
??????flink????kafka???????????????????????????? 
??????????????????????????????????????????????????????????????????????????????????????topic??????6????????????????????????????????????????????kafka??????broker??????????????????????????????


| |
??????
|
|
[email protected]
|
??????????????????????

??????flink????kafka????????

回复