You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Zia (Jira)" <ji...@apache.org> on 2022/03/02 20:11:00 UTC
[jira] [Updated] (CAMEL-17737) camel-salesforce consumer: message id not in sequence for platform events
[ https://issues.apache.org/jira/browse/CAMEL-17737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Zia updated CAMEL-17737:
------------------------
Component/s: camel-connector
camel-salesforce
Affects Version/s: 3.11.1
> 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,
> we are using Camel salesforce Source Kafka connector:- CamelSalesforceSourceConnector 0.11.1
> 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)