Github user satishd commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2480#discussion_r158699520
  
    --- Diff: 
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java
 ---
    @@ -182,6 +186,7 @@ public KafkaSpoutConfig(Builder<K, V> builder) {
             private boolean emitNullTuples = false;
             private ProcessingGuarantee processingGuarantee = 
DEFAULT_PROCESSING_GUARANTEE;
             private boolean tupleTrackingEnforced = false;
    +        public int metricsTimeBucketSizeInSecs = 
DEFAULT_METRICS_TIME_BUCKET_SIZE_SECONDS;
    --- End diff --
    
    access of this field should be private instead of public.


---

Reply via email to