I have a salesforce source connector that publishes platform events to Kafka topic. In case, the connector goes down in production for 5 minutes and comes back up, we have a property “salesforce.initial.start” on the connector that would publish all the messages on the salesforce event bus to the topic. So, while republishing them to the topic, is there a way to identify the messages that are already published to the topic before the connector went down. Can some one help me understand this use case?