I am using exponential retry in Kafka consumer. And it is working as expected but I need to add some more configuration to it. Suppose after the maximum retry attempt, the request is still not successful then I need to retry it for a fixed time thereafter.
Suppose the multiplier is 2 and the maximum retry attempt is 4 with an initial retry interval 1sec
Then retry sequence will be
1sec, 2 sec, 4 sec, 8 sec.
After the fourth attempt, I need retry to occur at a fixed interval (say after each 10sec) until the request is successful.
Is there any way I can achieve this?
How to retry for fixed amount of time after all previous retries are exhausted in Kafka consumer?
844 Views Asked by Suhaas At
1
There are 1 best solutions below
Related Questions in SPRING-BOOT
- Timing Issue with Spring Boot Annotation Configuration
- LightAdmin - Customise parsing DateTime with app timezone
- Creating distribution with repackaged spring boot jar using gradle application plugin
- Spring Boot MVC non-role based security
- Add JVM args to spring boot application
- The method and() is undefined for the type HttpSecurity
- swagger ui not working for swagger version 2
- Spring IO Platform 2.0 - Themes/Changes?
- JPA findDistinctPropertyBy magic method doesn't work as expected when using spring-boot-starter-jpa
- Spring boot check external service status on boot
- Running a specific spring batch job amongst several jobs contained withing a spring boot fat jar
- Adding security to rest api service built with Spring Boot app
- Spring Redirecting from Http to Https Breaks Rest Controller Test
- Service not starting using Spring-boot during integration tests
- Spring Boot Actuator Health Returning DOWN
Related Questions in APACHE-KAFKA
- Spark streaming + kafka throughput
- How to diagnose Kafka topics failing globally to be found
- kafka: what do 'soTimeout', 'bufferSize' and 'minBytes' mean for SimpleConsumer?
- Fail to create SparkContext
- Syntax error on tokens, delete these tokens - kafka spring integration demo application
- How could Kafka 0.8.2.1 with offsets.storage=kafka still require ZooKeeper?
- Message Queues: Per Message Guarantees
- How should a Kafka HLC figure out the # of partitions for a topic?
- Kafka multiple consumers for a partition
- Should Apache Kafka and Hadoop be installed seperatedly (on a diffrent cluster)?
- how does one combine kafka-node producer and node tail?
- How to fix NoClassDefFoundError with custom Kafka producer under Eclipse?
- Apache Samza's CheckpointTool won't give away partition offsets
- Offsets for Kafka Direct Approach in Spark 1.3.1
- Simulate kafka broker failures in multi node kafka cluster and what operations and tools to use to mitigate data loss issues
Related Questions in APACHE-KAFKA-STREAMS
- StreamsException: Extracted timestamp value is negative, which is not allowed
- Kafka Streams 0.10.1 "Failed to flush state store"
- KStreams app - excessive memory usage
- Aggregate Java objects in a list with Kafka Streams DSL windows
- How to read records from Kafka using Kafka-Stream by interval
- Kafka streams - joining two ktables invokes join function twice
- Building and querying state in Apache Kafka: Kafka Stream?
- Does the Kafka streams aggregation have any ordering guarantee?
- Tumbling window concept kafka streams
- Cannot access KTable from a different app as StateStore
- What are the differences between KTable vs GlobalKTable and leftJoin() vs outerJoin()?
- Join data from 4 topics in broker using Kafka Streams when updates are not same in each of the topics
- Joining Kafka Streams containing Java Hash Map Objects
- Kafka Streams: Failed to rebalance due to Change log state changing during restoring
- using kafka-streams to create a new KStream containing multiple aggregations
Related Questions in SPRING-RETRY
- Why Spring @Retryable does not provide retry?
- Spring batch 3, error at configuration load on IBM JVM (BackToBackPatternClassifier)
- Does @Retryable work with JDK Dynamic Proxies?
- @TransactionalEventListener, @Transactional and @Retryable flow
- Annotation for retrying all methods in a class instead of using @Retryable for each method
- How to change the spring retry template fixed back off policy based on the exception
- Spring Retry doesn't works when we use RetryTemplate?
- How can we get the JobId in the RetryContext?
- Print retry count with @Retryable
- Spring RetryTemplate return usage
- spring retry with custom boolean value from the request
- How to increase Atomikos default jta timeout based on the thread during Spring retry
- Delay SpringBoot application startup until db is up
- Spring Retry with for loop
- Is it possible to set RetryPolicy in spring-retry based on HttpStatus status code?
Related Questions in EXPONENTIAL-BACKOFF
- exponential backoff implementation in python
- How to resolve the error code 503 and 429 while reading all locations of all accounts using Google My Business Information API in Java
- Firebase Cloud Function: Retry behaviour and backoff times
- Implement Exponential Back off in NiFi using RetryFlowFile processor
- Is Exponential Backoff inbuilt in AWS SDK Boto3?
- Dynamically generated schedule interval?
- How to retry for fixed amount of time after all previous retries are exhausted in Kafka consumer?
- Python While Loop attempts restart to 0 if successful
- How does the exponential backoff configured in Google Pub/Sub's RetryPolicy work?
- Set customBackoff for AWS SDK JavaScript V3 retries
- HttpClient asyncRequest and exponential backoff
- Exponential Wait time in AWS Step Function
- ExponentialBackoff job Reload function Error: Call to undefined method
- In Python, is it possible to use 'exponential backoff' per request for batched HTTP requests?
- Polly RetryForever isn't retrying
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
Assuming you are using the
ExponentialBackOffPolicyin theRetryTemplate, you can set itsmaxIntervalproperty.If you are using a
SeekToCurrentErrorHandlerwith anExponentialBackOffinstead (which is preferred with modern versions of spring-kafka - to avoid a rebalance), it, too, has amaxIntervalproperty.