Repository: storm Updated Branches: refs/heads/1.1.x-branch bb4e68c58 -> e3020a3c7
STORM-2512: Make constructor public and add one more builder constructor Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/0a822fcf Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/0a822fcf Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/0a822fcf Branch: refs/heads/1.1.x-branch Commit: 0a822fcf339f67e662814f9a3d8dc41c9774bee3 Parents: bb4e68c Author: Priyank <[email protected]> Authored: Fri May 12 23:32:08 2017 -0700 Committer: Stig Rohde Døssing <[email protected]> Committed: Mon Aug 28 22:05:49 2017 +0200 ---------------------------------------------------------------------- .../java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/0a822fcf/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 5f8071f..e1c6c96 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 @@ -107,7 +107,11 @@ public class KafkaSpoutConfig<K, V> implements Serializable { private KafkaSpoutRetryService retryService = DEFAULT_RETRY_SERVICE; private long partitionRefreshPeriodMs = DEFAULT_PARTITION_REFRESH_PERIOD_MS; private boolean emitNullTuples = false; - + + public Builder(String bootstrapServers, String ... topics) { + this(bootstrapServers, (SerializableDeserializer) null, (SerializableDeserializer) null, new NamedSubscription(topics)); + } + public Builder(String bootstrapServers, SerializableDeserializer<K> keyDes, SerializableDeserializer<V> valDes, String ... topics) { this(bootstrapServers, keyDes, valDes, new NamedSubscription(topics)); } @@ -435,7 +439,7 @@ public class KafkaSpoutConfig<K, V> implements Serializable { private final long partitionRefreshPeriodMs; private final boolean emitNullTuples; - private KafkaSpoutConfig(Builder<K,V> builder) { + public KafkaSpoutConfig(Builder<K,V> builder) { this.kafkaProps = setDefaultsAndGetKafkaProps(builder.kafkaProps); this.subscription = builder.subscription; this.translator = builder.translator;
