SeekBy Timestamp is not working as expected if messages are sent in between the Execution

[deepakks-tibco]

If we provide the future timestamp and execute the Consumer activity.
It will start the consumer and wait for the messages to consume after that timestamp. But if we sent the messages in between the consumer still consume the messages before that timestamp.

Created a standalone consumer app. Start producer and standalone consumer with future timestamp example timestamp set as currentTimeMillis()+ 5 min. The consumer starts consuming all messages before timestamp.
Here is the standalone consumer code.

   PulsarClient client=PulsarClient.builder().serviceUrl("pulsar://localhost:6650").build();
	Consumer<byte[]> consumer=client.newConsumer().topic("test-topic-avro")
			.subscriptionName("subscription").subscriptionInitialPosition(SubscriptionInitialPosition.Latest)
			.subscribe();
	
	SimpleDateFormat sdf=new SimpleDateFormat("ddMMyy HH:mm");
	
	try {
	 		
		long timestamp=System.currentTimeMillis()+(5*60*1000);
		consumer.seek(timestamp);
		
		sdf.setTimeZone(TimeZone.getTimeZone( "IST"));
		System.out.println("Seeking time"+sdf.format(new Date(timestamp)));
		
	} catch (IOException e) {
		
		e.printStackTrace();
	}
	
	while(true)
	{
		Message<byte[]> msg=consumer.receive();
		System.out.println("received messages:"+new String(msg.getData()));
		System.out.println("received messages id:"+new String(msg.getMessageId().toString() ));
		System.out.println("publishtime: "+sdf.format(new Date( msg.getPublishTime())));
		
		consumer.acknowledge(msg);
		
	}

[lhotari]

Which Pulsar version? In Pulsar 4.0.2 there's a known issue with seek, also mentioned in the updated release notes with workaround instructions.

[deepakks-tibco]

Using Current version 4.0.2​