[
https://issues.apache.org/jira/browse/CAMEL-17737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrea Cosentino resolved CAMEL-17737.
--------------------------------------
Resolution: Invalid
Please open the issue only on camel-kafka-connector issues for
camel-kafka-connector project.
You already opened the same issue there
> camel-salesforce consumer: message id not in sequence for platform events
> -------------------------------------------------------------------------
>
> Key: CAMEL-17737
> URL: https://issues.apache.org/jira/browse/CAMEL-17737
> Project: Camel
> Issue Type: Bug
> Components: camel-connector, camel-salesforce
> Affects Versions: 3.11.1
> Reporter: Zia
> Priority: Major
>
> Hi All,
> while observing consumed messages in Camel salesforce consumer, i see message
> id in consumed message are not in sequence and have some jumps in between the
> message ID sequences. there are no errors as well in the logs. does it means
> camel salesforce consumer missing some platform event messages? Kindly help
>
>
> 2022-03-03 01:24:52,664] INFO Received Exchange
> BBE93EB9D4320D3-0000000000003AFE with Message
> BBE93EB9D4320D3-{*}0000000000003AFE{*} from Endpoint
> salesforce:///event/LoginEventStream?backoffIncrement=1000&replayId=-2
> (org.apache.camel.kafkaconnector.CamelSourceTask:233)
> [2022-03-03 01:24:52,664] INFO Received Exchange
> BBE93EB9D4320D3-0000000000003AFF with Message
> {*}BBE93EB9D4320D3{*}-0000000000003AFF from Endpoint
> salesforce:///event/LoginEventStream?backoffIncrement=1000&replayId=-2
> (org.apache.camel.kafkaconnector.CamelSourceTask:233)
> [2022-03-03 01:24:52,664] INFO Received Exchange
> BBE93EB9D4320D3-0000000000003B00 with Message
> BBE93EB9D4320D3-{*}0000000000003B00{*} from Endpoint
> salesforce:///event/LoginEventStream?backoffIncrement=1000&replayId=-2
> (org.apache.camel.kafkaconnector.CamelSourceTask:233)
> [2022-03-03 01:24:52,953] INFO Received Exchange
> BBE93EB9D4320D3-0000000000003C19 with Message
> BBE93EB9D4320D3-{*}0000000000003C19{*} from Endpoint
> salesforce:///event/LoginEventStream?backoffIncrement=1000&replayId=-2
> (org.apache.camel.kafkaconnector.CamelSourceTask:233)
> [2022-03-03 01:24:52,954] INFO Received Exchange
> BBE93EB9D4320D3-0000000000003C23 with Message
> BBE93EB9D4320D3-{*}0000000000003C23{*} from Endpoint
> salesforce:///event/LoginEventStream?backoffIncrement=1000&replayId=-2
> (org.apache.camel.kafkaconnector.CamelSourceTask:233)
> [2022-03-03 01:24:52,954] INFO Received Exchange
> BBE93EB9D4320D3-0000000000003C2C with Message
> BBE93EB9D4320D3-{*}0000000000003C2C{*} from Endpoint
> salesforce:///event/LoginEventStream?backoffIncrement=1000&replayId=-2
> (org.apache.camel.kafkaconnector.CamelSourceTask:233)
> [2022-03-03 01:24:52,954] INFO Received Exchange
> BBE93EB9D4320D3-0000000000003C32 with Message
> BBE93EB9D4320D3-{*}0000000000003C32{*} from Endpoint
> salesforce:///event/LoginEventStream?backoffIncrement=1000&replayId=-2
> (org.apache.camel.kafkaconnector.CamelSourceTask:233)
> [2022-03-03 01:24:52,954] INFO Received Exchange
> BBE93EB9D4320D3-0000000000003C37 with Message
> BBE93EB9D4320D3-{*}0000000000003C37{*} from Endpoint
> salesforce:///event/LoginEventStream?backoffIncrement=1000&replayId=-2
> (org.apache.camel.kafkaconnector.CamelSourceTask:233)
> [2022-03-03 01:24:52,955] INFO Received Exchange
> BBE93EB9D4320D3-0000000000003C3D with Message
> BBE93EB9D4320D3-{*}0000000000003C3D{*} from Endpoint
> salesforce:///event/LoginEventStream?backoffIncrement=1000&replayId=-2
> (org.apache.camel.kafkaconnector.CamelSourceTask:233)
> [2022-03-03 01:24:52,955] INFO Received Exchange
> BBE93EB9D4320D3-0000000000003C42 with Message
> BBE93EB9D4320D3-{*}0000000000003C42{*} from Endpoint
> salesforce:///event/LoginEventStream?backoffIncrement=1000&replayId=-2
> (org.apache.camel.kafkaconnector.CamelSourceTask:233)
> [2022-03-03 01:24:52,955] INFO Received Exchange
> BBE93EB9D4320D3-0000000000003C47 with Message
> BBE93EB9D4320D3-{*}0000000000003C47{*} from Endpoint
> salesforce:///event/LoginEventStream?backoffIncrement=1000&replayId=-2
> (org.apache.camel.kafkaconnector.CamelSourceTask:233)
> [2022-03-03 01:24:52,955] INFO Received Exchange
> BBE93EB9D4320D3-0000000000003C4E with Message
> BBE93EB9D4320D3-{*}0000000000003C4E{*} from Endpoint
> salesforce:///event/LoginEventStream?backoffIncrement=1000&replayId=-2
> (org.apache.camel.kafkaconnector.CamelSourceTask:233)
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
