- try
- {
- log.debug("{} - Waiting for async commit to complete", id);
- commitDone.await();
- }
- catch (InterruptedException e)
- {
- log.warn(
- "{} - Interrupted while waiting for async commit in onPartitionsRevoked({})",
- id,
- partitions,
- e);
- }
+ @Override
+ public void enableCommits()
+ {
+ commitsEnabled = true;
+ }
+
+ @Override
+ public void disableCommits()
+ {
+ commitsEnabled = false;