[
https://issues.apache.org/jira/browse/CAMEL-17737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zia updated CAMEL-17737:
------------------------
Description:
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)
was:
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)
> 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)
