Zia created CAMEL-17737:
---------------------------
Summary: 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
Reporter: Zia
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)
