review

Author: astubbs

README.adoc

@@ -246,6 +246,7 @@ without operational burden or harming the cluster's performance
 * Java 8 compatibility
 * Throttle control and broker liveliness management
 * Clean draining shutdown cycle
+* Manual Pause / Resume (pausing of partitions is also automatic, whenever back pressure has built up)
 
 //image:https://codecov.io/gh/astubbs/parallel-consumer/branch/master/graph/badge.svg["Coverage",https://codecov.io/gh/astubbs/parallel-consumer]
 //image:https://travis-ci.com/astubbs/parallel-consumer.svg?branch=master["Build Status", link="https://travis-ci.com/astubbs/parallel-consumer"]
@@ -465,7 +466,6 @@ See {issues_link}/12[issue #12], and the `ParallelConsumer` JavaDoc:
  * @param <K> key consume / produce key type
  * @param <V> value consume / produce value type
  * @see AbstractParallelEoSStreamProcessor
- * @see #poll(Consumer)
  */
 ----
 

parallel-consumer-core/src/main/java/io/confluent/parallelconsumer/internal/AbstractParallelEoSStreamProcessor.java

@@ -60,7 +60,7 @@ public abstract class AbstractParallelEoSStreamProcessor<K, V> implements Parall
      * Key for the work container descriptor that will be added to the {@link MDC diagnostic context} while inside a
      * user function.
      */
-    public static final String MDC_WORK_CONTAINER_DESCRIPTOR = "offset";
+    private static final String MDC_WORK_CONTAINER_DESCRIPTOR = "offset";
 
     @Getter(PROTECTED)
     protected final ParallelConsumerOptions options;

parallel-consumer-core/src/test/resources/logback-test.xml

@@ -28,7 +28,7 @@
 
     <!-- primary -->
     <logger name="io.confluent.parallelconsumer" level="info"/>
-    <!--    <logger name="io.confluent.parallelconsumer" level="debug"/>-->
+        <logger name="io.confluent.parallelconsumer" level="debug"/>
 
     <!--    <logger name="io.confluent.csid" level="debug"/>-->
 

src/docs/README.adoc

@@ -244,6 +244,7 @@ without operational burden or harming the cluster's performance
 * Java 8 compatibility
 * Throttle control and broker liveliness management
 * Clean draining shutdown cycle
+* Manual Pause / Resume (pausing of partitions is also automatic, whenever back pressure has built up)
 
 //image:https://codecov.io/gh/astubbs/parallel-consumer/branch/master/graph/badge.svg["Coverage",https://codecov.io/gh/astubbs/parallel-consumer]
 //image:https://travis-ci.com/astubbs/parallel-consumer.svg?branch=master["Build Status", link="https://travis-ci.com/astubbs/parallel-consumer"]