Repository: storm Updated Branches: refs/heads/master 9d52435c5 -> 61a944fd1
MINOR: Use booleans instead of strings for 'enable.auto.commit' setting Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/77492802 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/77492802 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/77492802 Branch: refs/heads/master Commit: 774928028f2d06af5d68e13f0fb745561c2aa4a0 Parents: 8e4a146 Author: Stig Rohde Døssing <[email protected]> Authored: Sun Nov 19 11:00:37 2017 +0100 Committer: Stig Rohde Døssing <[email protected]> Committed: Sun Nov 19 11:00:37 2017 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java | 4 ++-- .../java/org/apache/storm/kafka/spout/KafkaSpoutConfigTest.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/77492802/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java index ca8dcee..6c792ab 100644 --- a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java +++ b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java @@ -441,7 +441,7 @@ public class KafkaSpoutConfig<K, V> implements Serializable { + " Instead use KafkaSpoutConfig.Builder.setProcessingGuarantee"); } if (builder.processingGuarantee == ProcessingGuarantee.NONE) { - builder.kafkaProps.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "true"); + builder.kafkaProps.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, true); } else { String autoOffsetResetPolicy = (String)builder.kafkaProps.get(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG); if (builder.processingGuarantee == ProcessingGuarantee.AT_LEAST_ONCE) { @@ -464,7 +464,7 @@ public class KafkaSpoutConfig<K, V> implements Serializable { + " Some messages may be processed more than once."); } } - builder.kafkaProps.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false"); + builder.kafkaProps.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, false); } } http://git-wip-us.apache.org/repos/asf/storm/blob/77492802/external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutConfigTest.java ---------------------------------------------------------------------- diff --git a/external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutConfigTest.java b/external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutConfigTest.java index e42719b..a3fc984 100644 --- a/external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutConfigTest.java +++ b/external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutConfigTest.java @@ -40,7 +40,7 @@ public class KafkaSpoutConfigTest { assertTrue(conf.getTranslator() instanceof DefaultRecordTranslator); HashMap<String, Object> expected = new HashMap<>(); expected.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:1234"); - expected.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false"); + expected.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, false); expected.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); expected.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class); expected.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
