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?
This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.