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

    https://github.com/apache/storm/pull/2537#discussion_r165830248
  
    --- Diff: 
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java
 ---
    @@ -453,37 +451,33 @@ public Builder(String bootstrapServers, Subscription 
subscription) {
             return builder;
         }
     
    -    private static void setAutoCommitMode(Builder<?, ?> builder) {
    +    private static void setPropsToFitProcessingGuarantee(Builder<?, ?> 
builder) {
    --- End diff --
    
    setKafkaPropsForProcessingGuarantee


---

Reply via email to