Spring Cloud Stream Consumer receives the same message more than oneSpring Integration Kafka (2.0.0) with Spring Kafka 1.0.2 consumers receive duplicate messageSpring Integration Kafka Consumer Listener not Receiving messagesSpring cloud stream application configurable topic nameSpring cloud stream kafka consumer that bind to multiple topicsBind RabbitMQ consumer using Spring Cloud Stream to an existing queueCan I bind to multiple consumer groups with Spring Cloud Stream?Spring Cloud Stream topic per message for different consumersSpring Cloud Stream Message HandlingSpring Cloud Stream Kafka Binder autoCommitOnError=false get unexpected behavior
Is there a sentence that begins with “them”?
Might have gotten a coworker sick, should I address this?
Determining if file in projected or geographic coordinates using ArcGIS Desktop?
CBP interview, how serious should I take it?
How to circle together certain entries of a matrix?
Why would thermal imaging be used to locate the Chandrayaan-2 lander?
What is this dollar sign ($) icon in my Menu Bar?
Calculate time difference between two dates
Was Robin Hood's point of view ethically sound?
Are Democrats more likely to believe Astrology is a science?
Do any aircraft carry boats?
Are programming languages necessary/useful for operations research practitioner?
Expected value until a success?
Usage of Offrir and Donner
Is English tonal for some words, like "permit"?
I changed a word from a source, how do I cite it correctly?
Gas pipes - why does gas burn "outwards?"
How does Vivi differ from other Black Mages?
How do I politely hint customers to leave my store, without pretending to need leave store myself?
What are the advantages and disadvantages of Preprints.org compared with arXiv?
Are scroll bars dead in 2019?
How to progress with CPLEX/Gurobi
Does the mana ability restriction of Pithing Needle refer to the cost or the effect of an activated ability?
Why was "leaping into the river" a valid trial outcome to prove one's innocence?
Spring Cloud Stream Consumer receives the same message more than one
Spring Integration Kafka (2.0.0) with Spring Kafka 1.0.2 consumers receive duplicate messageSpring Integration Kafka Consumer Listener not Receiving messagesSpring cloud stream application configurable topic nameSpring cloud stream kafka consumer that bind to multiple topicsBind RabbitMQ consumer using Spring Cloud Stream to an existing queueCan I bind to multiple consumer groups with Spring Cloud Stream?Spring Cloud Stream topic per message for different consumersSpring Cloud Stream Message HandlingSpring Cloud Stream Kafka Binder autoCommitOnError=false get unexpected behavior
.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty margin-bottom:0;
we are listening to the topic that produced by another API. Consumer, process message but sometimes it takes a more than 4-5 seconds. Then, spring cloud stream sends the same message to the consumer. Therefore, an error occurred on the consumer side.
@StreamListener(ORDER_CREATED)
void orderCreated(Event event)
log.info("ORDER CREATED event received.")
//process message
//sometimes take a more than 4-5 seconds
log.info("Order successfully STARTED.")
Should consumer consume message faster as possible? Or should be async in the consumer?
spring stream cloud consumer
add a comment |
we are listening to the topic that produced by another API. Consumer, process message but sometimes it takes a more than 4-5 seconds. Then, spring cloud stream sends the same message to the consumer. Therefore, an error occurred on the consumer side.
@StreamListener(ORDER_CREATED)
void orderCreated(Event event)
log.info("ORDER CREATED event received.")
//process message
//sometimes take a more than 4-5 seconds
log.info("Order successfully STARTED.")
Should consumer consume message faster as possible? Or should be async in the consumer?
spring stream cloud consumer
add a comment |
we are listening to the topic that produced by another API. Consumer, process message but sometimes it takes a more than 4-5 seconds. Then, spring cloud stream sends the same message to the consumer. Therefore, an error occurred on the consumer side.
@StreamListener(ORDER_CREATED)
void orderCreated(Event event)
log.info("ORDER CREATED event received.")
//process message
//sometimes take a more than 4-5 seconds
log.info("Order successfully STARTED.")
Should consumer consume message faster as possible? Or should be async in the consumer?
spring stream cloud consumer
we are listening to the topic that produced by another API. Consumer, process message but sometimes it takes a more than 4-5 seconds. Then, spring cloud stream sends the same message to the consumer. Therefore, an error occurred on the consumer side.
@StreamListener(ORDER_CREATED)
void orderCreated(Event event)
log.info("ORDER CREATED event received.")
//process message
//sometimes take a more than 4-5 seconds
log.info("Order successfully STARTED.")
Should consumer consume message faster as possible? Or should be async in the consumer?
spring stream cloud consumer
spring stream cloud consumer
asked Mar 28 at 7:48
Alican AkkuşAlican Akkuş
194 bronze badges
194 bronze badges
add a comment |
add a comment |
0
active
oldest
votes
Your Answer
StackExchange.ifUsing("editor", function ()
StackExchange.using("externalEditor", function ()
StackExchange.using("snippets", function ()
StackExchange.snippets.init();
);
);
, "code-snippets");
StackExchange.ready(function()
var channelOptions =
tags: "".split(" "),
id: "1"
;
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function()
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled)
StackExchange.using("snippets", function()
createEditor();
);
else
createEditor();
);
function createEditor()
StackExchange.prepareEditor(
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader:
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/4.0/"u003ecc by-sa 4.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
,
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
);
);
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55392491%2fspring-cloud-stream-consumer-receives-the-same-message-more-than-one%23new-answer', 'question_page');
);
Post as a guest
Required, but never shown
0
active
oldest
votes
0
active
oldest
votes
active
oldest
votes
active
oldest
votes
Is this question similar to what you get asked at work? Learn more about asking and sharing private information with your coworkers using Stack Overflow for Teams.
Is this question similar to what you get asked at work? Learn more about asking and sharing private information with your coworkers using Stack Overflow for Teams.
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55392491%2fspring-cloud-stream-consumer-receives-the-same-message-more-than-one%23new-answer', 'question_page');
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown