Skip to content
This repository has been archived by the owner on Nov 28, 2023. It is now read-only.

Commit

Permalink
Add TRACE logging for KafkaConsumer shutdown
Browse files Browse the repository at this point in the history
  • Loading branch information
@nicktelford
nicktelford committed Oct 1, 2014
1 parent 18cc756 commit 41f5a4e
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 0 deletions.
4 changes: 4 additions & 0 deletions ...extra-kafka/src/main/java/com/datasift/dropwizard/kafka/consumer/SynchronousConsumer.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -151,9 +151,13 @@ public void start() throws Exception {
*/
@Override
public void stop() throws Exception {
LOG.trace("Shutting down Connector");
connector.shutdown();
LOG.trace("Connector shut down");
LOG.trace("Shutting down Executor");
executor.shutdown();
executor.awaitTermination(shutdownGracePeriod.getQuantity(), shutdownGracePeriod.getUnit());
LOG.trace("Executor shut down");
}

/**
Expand Down
4 changes: 4 additions & 0 deletions ...xtra-kafka7/src/main/java/com/datasift/dropwizard/kafka/consumer/SynchronousConsumer.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -147,9 +147,13 @@ public void start() throws Exception {
*/
@Override
public void stop() throws Exception {
LOG.trace("Shutting down Connector");
connector.shutdown();
LOG.trace("Connector shut down");
LOG.trace("Shutting down Executor");
executor.shutdown();
executor.awaitTermination(shutdownGracePeriod.getQuantity(), shutdownGracePeriod.getUnit());
LOG.trace("Executor shut down");
}

/**
Expand Down

0 comments on commit 41f5a4e

Please sign in to comment.