Skip to content

Commit

Permalink
Decrease the sleep when pausing the Kafka consumer to 1 second when t…
Browse files Browse the repository at this point in the history
…he circuit breaker is in use. (#4947)

Signed-off-by: David Venable <dlv@amazon.com>
  • Loading branch information
dlvenable authored Sep 13, 2024
1 parent 627ae9f commit 72063d6
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -357,7 +357,7 @@ public void run() {
LOG.debug("Pause and skip consuming from Kafka topic due to an external condition: {}", pauseConsumePredicate);
paused = true;
consumer.pause(consumer.assignment());
Thread.sleep(10000);
Thread.sleep(1000);
continue;
} else if(paused) {
LOG.debug("Resume consuming from Kafka topic.");
Expand Down

0 comments on commit 72063d6

Please sign in to comment.