在 WindowOperator 类中
processElement() 处理每一个到来的元素，我发现这里返回结果是fire的也能够触发窗口计算
TriggerResult triggerResult = triggerContext.onElement(element);
if (triggerResult.isFire()) {
ACC contents = windowState.get();
if (contents == null) {
continue;
}
emitWindowContents(window, contents);}
问题实际上就是在kafka server 那里看不到消费者组，也就是group id ,
表现出来的现象就是就是flink重启后，根本就没有按上次的offset开始继续消费
也就是之前flink，一直都没有提交过offset,也看不到消费者组,
可以用blink那个版本的pom测试一下
--
发件人：Biao Liu
发送时间：2019年6月25日(星期二) 12:10
收件人：user-zh ; 雷水鱼
主 题：Re: blink 版本 消费kafka
现象
使用这个pom ,在kafka 里看不到group id
com.alibaba.blink
flink-streaming-scala_2.11
blink-3.2.2
org.slf4j
slf4j-api
com.alibaba.blink
flink-connector-kafka-0.11_2.11
blink-3.2.0
org.slf4j
slf4j-api
使用开源版本，可以看到在kafka 看到group id
org.apache.flink
flink-streaming-java_2.12
