title: Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic set to 'ProcessingTime'
body: <p>I have following topology</p>
  <pre><code>env.setTimeCharacteristic(TimeCharacteristic.EventTime);
  DataStream&lt;Event&gt; eventSource = env.addSource(createEventSource(kafkaTopic, kafkaBroker))
       .assignTimestampANdWatermarks(WatermarksStrategy
                                 .&lt;Event&gt;forBoundedOutOfOrderness(Duration.ofSecond(20)))
       .keyBy((event)-&gt;event.getId().toString());
  
  eventSource.window(TumblingEventTimeWindows.of(Time.seconds(20))
      .process(new MyProcessWindowFunction())
      .name(&quot;TESTING&quot;);
  
  public static class MyProcessWindowFunction extends ProcessWindowFunction&lt;Event,Event, String, TimeWindow&gt;
  {
    @Override
    public void process(String key, Context context, Iterable&lt;Event&gt; input, Collector&lt;Event&gt; out)
    {
       logger.info(&quot;currentTime = {}, currentWatermark = {} &quot;,context.currentProcessingTime(), context.currentWatermark());
       long count = 0;
       for( Event in : input)
       {
         count++;
         out.collect(in);
       }
       logger.info(&quot; count = {}&quot;,count);
    }
  }
  
  public static FlinkKafkaConsumer&lt;Event&gt; createEventSource(String topic, String broker)
  {
    Properties prop = new Properties();
    prop.setProperty(&quot;bootstrap.servers&quot;,broker);
    prop.setproperty(&quot;group.id&quot;, &quot;flinkPOCtest&quot;);
    FlinkKafkaConsumer&lt;Event&gt; kafkaConsumer = new FlinkKafkaConsumer&lt;&gt;(topic,
                                                                       new AvroDeserializer&lt;Event&gt;(Event.class),
                                                                        prop);
      
    return kafkaConsumer;
  
  }
  </code></pre>
  <p>Adding</p>
  <pre><code>env.setTimeCharacteristic(TimeCharacteristic.EventTime);
  </code></pre>
  <p>Along with calling assignTimestampANdWatermarks on stream did solve the problem reported in earlier post where I was getting Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic set to 'ProcessingTime'</p>