我写了一个非常简单的flink流媒体作业，它使用 FlinkKafkaConsumer082 .

protected DataStream<String> getKafkaStream(StreamExecutionEnvironment env, String topic) {
    Properties result = new Properties();
    result.put("bootstrap.servers", getBrokerUrl());
    result.put("zookeeper.connect", getZookeeperUrl());
    result.put("group.id", getGroup());

        return env.addSource(
                new FlinkKafkaConsumer082<>(
                        topic,
                        new SimpleStringSchema(), result);
}

这是非常好的工作，每当我把Kafka的主题，它是由我的Flink工作接收和处理的东西。现在我试着看看如果我的flink工作因为某种原因不在线会发生什么。所以我关掉了flink的工作，一直给Kafka发信息。然后我又开始了我的flink工作，希望它能处理同时发送的消息。
然而，我得到了这个信息：

No prior offsets found for some partitions in topic collector.Customer. Fetched the following start offsets [FetchPartition {partition=0, offset=25}]

因此，它基本上忽略了自上次关闭flink作业以来出现的所有消息，只是在队列末尾开始读取。从 FlinkKafkaConsumer082 我收集到，它自动负责与kafka代理同步处理的偏移量。然而，情况似乎并非如此。
我使用单节点kafka安装（kafka发行版附带的安装）和单节点zookeper安装（也是与kafka发行版捆绑的安装）。
我怀疑这是某种配置错误或类似的东西，但我真的不知道从哪里开始寻找。有没有其他人有这个问题，也许解决了？