| <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> |
| <!-- NewPage --> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc --> |
| <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> |
| <title>KafkaSpoutConfig.Builder (Storm 1.1.2 API)</title> |
| <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> |
| <script type="text/javascript" src="../../../../../script.js"></script> |
| </head> |
| <body> |
| <script type="text/javascript"><!-- |
| try { |
| if (location.href.indexOf('is-external=true') == -1) { |
| parent.document.title="KafkaSpoutConfig.Builder (Storm 1.1.2 API)"; |
| } |
| } |
| catch(err) { |
| } |
| //--> |
| var methods = {"i0":10,"i1":42,"i2":10,"i3":42,"i4":10,"i5":42,"i6":42,"i7":42,"i8":42,"i9":42,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":42,"i24":42,"i25":42,"i26":42,"i27":10,"i28":10,"i29":42,"i30":42}; |
| var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]}; |
| var altColor = "altColor"; |
| var rowColor = "rowColor"; |
| var tableTab = "tableTab"; |
| var activeTableTab = "activeTableTab"; |
| </script> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| <!-- ========= START OF TOP NAVBAR ======= --> |
| <div class="topNav"><a name="navbar.top"> |
| <!-- --> |
| </a> |
| <div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div> |
| <a name="navbar.top.firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="../../../../../overview-summary.html">Overview</a></li> |
| <li><a href="package-summary.html">Package</a></li> |
| <li class="navBarCell1Rev">Class</li> |
| <li><a href="class-use/KafkaSpoutConfig.Builder.html">Use</a></li> |
| <li><a href="package-tree.html">Tree</a></li> |
| <li><a href="../../../../../deprecated-list.html">Deprecated</a></li> |
| <li><a href="../../../../../index-all.html">Index</a></li> |
| <li><a href="../../../../../help-doc.html">Help</a></li> |
| </ul> |
| </div> |
| <div class="subNav"> |
| <ul class="navList"> |
| <li><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.html" title="class in org.apache.storm.kafka.spout"><span class="typeNameLink">Prev Class</span></a></li> |
| <li><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.FirstPollOffsetStrategy.html" title="enum in org.apache.storm.kafka.spout"><span class="typeNameLink">Next Class</span></a></li> |
| </ul> |
| <ul class="navList"> |
| <li><a href="../../../../../index.html?org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" target="_top">Frames</a></li> |
| <li><a href="KafkaSpoutConfig.Builder.html" target="_top">No Frames</a></li> |
| </ul> |
| <ul class="navList" id="allclasses_navbar_top"> |
| <li><a href="../../../../../allclasses-noframe.html">All Classes</a></li> |
| </ul> |
| <div> |
| <script type="text/javascript"><!-- |
| allClassesLink = document.getElementById("allclasses_navbar_top"); |
| if(window==top) { |
| allClassesLink.style.display = "block"; |
| } |
| else { |
| allClassesLink.style.display = "none"; |
| } |
| //--> |
| </script> |
| </div> |
| <div> |
| <ul class="subNavList"> |
| <li>Summary: </li> |
| <li>Nested | </li> |
| <li>Field | </li> |
| <li><a href="#constructor.summary">Constr</a> | </li> |
| <li><a href="#method.summary">Method</a></li> |
| </ul> |
| <ul class="subNavList"> |
| <li>Detail: </li> |
| <li>Field | </li> |
| <li><a href="#constructor.detail">Constr</a> | </li> |
| <li><a href="#method.detail">Method</a></li> |
| </ul> |
| </div> |
| <a name="skip.navbar.top"> |
| <!-- --> |
| </a></div> |
| <!-- ========= END OF TOP NAVBAR ========= --> |
| <!-- ======== START OF CLASS DATA ======== --> |
| <div class="header"> |
| <div class="subTitle">org.apache.storm.kafka.spout</div> |
| <h2 title="Class KafkaSpoutConfig.Builder" class="title">Class KafkaSpoutConfig.Builder<K,V></h2> |
| </div> |
| <div class="contentContainer"> |
| <ul class="inheritance"> |
| <li><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">java.lang.Object</a></li> |
| <li> |
| <ul class="inheritance"> |
| <li>org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder<K,V></li> |
| </ul> |
| </li> |
| </ul> |
| <div class="description"> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <dl> |
| <dt>Enclosing class:</dt> |
| <dd><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.html" title="type parameter in KafkaSpoutConfig">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.html" title="type parameter in KafkaSpoutConfig">V</a>></dd> |
| </dl> |
| <hr> |
| <br> |
| <pre>public static class <span class="typeNameLabel">KafkaSpoutConfig.Builder<K,V></span> |
| extends <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></pre> |
| </li> |
| </ul> |
| </div> |
| <div class="summary"> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <!-- ======== CONSTRUCTOR SUMMARY ======== --> |
| <ul class="blockList"> |
| <li class="blockList"><a name="constructor.summary"> |
| <!-- --> |
| </a> |
| <h3>Constructor Summary</h3> |
| <table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Constructor Summary table, listing constructors, and an explanation"> |
| <caption><span>Constructors</span><span class="tabEnd"> </span></caption> |
| <tr> |
| <th class="colOne" scope="col">Constructor and Description</th> |
| </tr> |
| <tr class="altColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#Builder-java.lang.String-java.lang.Class-java.lang.Class-java.util.Collection-">Builder</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>>> keyDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>>> valDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> topics)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <code>#Builder(java.lang.String, java.util.Collection) </code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#Builder-java.lang.String-java.lang.Class-java.lang.Class-java.util.regex.Pattern-">Builder</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>>> keyDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>>> valDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/util/regex/Pattern.html?is-external=true" title="class or interface in java.util.regex">Pattern</a> topics)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <code>#Builder(java.lang.String, java.util.regex.Pattern) </code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#Builder-java.lang.String-java.lang.Class-java.lang.Class-java.lang.String...-">Builder</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>>> keyDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>>> valDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>... topics)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <code>#Builder(java.lang.String, java.lang.String...)</code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#Builder-java.lang.String-java.lang.Class-java.lang.Class-org.apache.storm.kafka.spout.Subscription-">Builder</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>>> keyDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>>> valDes, |
| <a href="../../../../../org/apache/storm/kafka/spout/Subscription.html" title="class in org.apache.storm.kafka.spout">Subscription</a> subscription)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <code>#Builder(java.lang.String, org.apache.storm.kafka.spout.Subscription) </code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#Builder-java.lang.String-java.util.Collection-">Builder</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> topics)</code> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#Builder-java.lang.String-java.util.regex.Pattern-">Builder</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/util/regex/Pattern.html?is-external=true" title="class or interface in java.util.regex">Pattern</a> topics)</code> </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#Builder-java.lang.String-org.apache.storm.kafka.spout.SerializableDeserializer-org.apache.storm.kafka.spout.SerializableDeserializer-java.util.Collection-">Builder</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>> keyDes, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> valDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> topics)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <code>#Builder(java.lang.String, java.util.Collection) </code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#Builder-java.lang.String-org.apache.storm.kafka.spout.SerializableDeserializer-org.apache.storm.kafka.spout.SerializableDeserializer-java.util.regex.Pattern-">Builder</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>> keyDes, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> valDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/util/regex/Pattern.html?is-external=true" title="class or interface in java.util.regex">Pattern</a> topics)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <code>#Builder(java.lang.String, java.util.regex.Pattern) </code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#Builder-java.lang.String-org.apache.storm.kafka.spout.SerializableDeserializer-org.apache.storm.kafka.spout.SerializableDeserializer-java.lang.String...-">Builder</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>> keyDes, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> valDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>... topics)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <code>#Builder(java.lang.String, java.lang.String...)</code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </div> |
| </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#Builder-java.lang.String-org.apache.storm.kafka.spout.SerializableDeserializer-org.apache.storm.kafka.spout.SerializableDeserializer-org.apache.storm.kafka.spout.Subscription-">Builder</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>> keyDes, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> valDes, |
| <a href="../../../../../org/apache/storm/kafka/spout/Subscription.html" title="class in org.apache.storm.kafka.spout">Subscription</a> subscription)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <code>#Builder(java.lang.String, org.apache.storm.kafka.spout.Subscription) </code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </div> |
| </td> |
| </tr> |
| <tr class="altColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#Builder-java.lang.String-java.lang.String...-">Builder</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>... topics)</code> </td> |
| </tr> |
| <tr class="rowColor"> |
| <td class="colOne"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#Builder-java.lang.String-org.apache.storm.kafka.spout.Subscription-">Builder</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="../../../../../org/apache/storm/kafka/spout/Subscription.html" title="class in org.apache.storm.kafka.spout">Subscription</a> subscription)</code> |
| <div class="block">Create a KafkaSpoutConfig builder with default property values and no key/value deserializers.</div> |
| </td> |
| </tr> |
| </table> |
| </li> |
| </ul> |
| <!-- ========== METHOD SUMMARY =========== --> |
| <ul class="blockList"> |
| <li class="blockList"><a name="method.summary"> |
| <!-- --> |
| </a> |
| <h3>Method Summary</h3> |
| <table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation"> |
| <caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span><span id="t6" class="tableTab"><span><a href="javascript:show(32);">Deprecated Methods</a></span><span class="tabEnd"> </span></span></caption> |
| <tr> |
| <th class="colFirst" scope="col">Modifier and Type</th> |
| <th class="colLast" scope="col">Method and Description</th> |
| </tr> |
| <tr id="i0" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#build--">build</a></span>()</code> </td> |
| </tr> |
| <tr id="i1" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setBootstrapServers-java.lang.String-">setBootstrapServers</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> servers)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG</code> instead</span></div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i2" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setEmitNullTuples-boolean-">setEmitNullTuples</a></span>(boolean emitNullTuples)</code> |
| <div class="block">Specifies if the spout should emit null tuples to the component downstream, or rather not emit and directly ack them.</div> |
| </td> |
| </tr> |
| <tr id="i3" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setFetchMinBytes-int-">setFetchMinBytes</a></span>(int bytes)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.FETCH_MIN_BYTES_CONFIG</code> instead</span></div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i4" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setFirstPollOffsetStrategy-org.apache.storm.kafka.spout.KafkaSpoutConfig.FirstPollOffsetStrategy-">setFirstPollOffsetStrategy</a></span>(<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.FirstPollOffsetStrategy.html" title="enum in org.apache.storm.kafka.spout">KafkaSpoutConfig.FirstPollOffsetStrategy</a> firstPollOffsetStrategy)</code> |
| <div class="block">Sets the offset used by the Kafka spout in the first poll to Kafka broker upon process start.</div> |
| </td> |
| </tr> |
| <tr id="i5" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setGroupId-java.lang.String-">setGroupId</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.GROUP_ID_CONFIG</code> instead</span></div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i6" class="altColor"> |
| <td class="colFirst"><code><NK> <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><NK,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setKey-java.lang.Class-">setKey</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<NK>> clazz)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code> instead</span></div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i7" class="rowColor"> |
| <td class="colFirst"><code><NK> <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><NK,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setKey-org.apache.storm.kafka.spout.SerializableDeserializer-">setKey</a></span>(<a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><NK> keyDeserializer)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> instead</span></div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i8" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setMaxPartitionFectchBytes-int-">setMaxPartitionFectchBytes</a></span>(int bytes)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.MAX_PARTITION_FETCH_BYTES_CONFIG</code> instead</span></div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i9" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setMaxPollRecords-int-">setMaxPollRecords</a></span>(int records)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.MAX_POLL_RECORDS_CONFIG</code> instead</span></div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i10" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setMaxUncommittedOffsets-int-">setMaxUncommittedOffsets</a></span>(int maxUncommittedOffsets)</code> |
| <div class="block">Defines the max number of polled offsets (records) that can be pending commit, before another poll can take place.</div> |
| </td> |
| </tr> |
| <tr id="i11" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setMetricsTimeBucketSizeInSecs-int-">setMetricsTimeBucketSizeInSecs</a></span>(int metricsTimeBucketSizeInSecs)</code> |
| <div class="block">The time period that metrics data in bucketed into.</div> |
| </td> |
| </tr> |
| <tr id="i12" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setOffsetCommitPeriodMs-long-">setOffsetCommitPeriodMs</a></span>(long offsetCommitPeriodMs)</code> |
| <div class="block">Specifies the period, in milliseconds, the offset commit task is periodically called.</div> |
| </td> |
| </tr> |
| <tr id="i13" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setPartitionRefreshPeriodMs-long-">setPartitionRefreshPeriodMs</a></span>(long partitionRefreshPeriodMs)</code> |
| <div class="block">Sets partition refresh period in milliseconds.</div> |
| </td> |
| </tr> |
| <tr id="i14" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setPollTimeoutMs-long-">setPollTimeoutMs</a></span>(long pollTimeoutMs)</code> |
| <div class="block">Specifies the time, in milliseconds, spent waiting in poll if data is not available.</div> |
| </td> |
| </tr> |
| <tr id="i15" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProcessingGuarantee-org.apache.storm.kafka.spout.KafkaSpoutConfig.ProcessingGuarantee-">setProcessingGuarantee</a></span>(<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html" title="enum in org.apache.storm.kafka.spout">KafkaSpoutConfig.ProcessingGuarantee</a> processingGuarantee)</code> |
| <div class="block">Specifies which processing guarantee the spout should offer.</div> |
| </td> |
| </tr> |
| <tr id="i16" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.util.Map-">setProp</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> props)</code> |
| <div class="block">Set multiple <code>KafkaConsumer</code> properties.</div> |
| </td> |
| </tr> |
| <tr id="i17" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.util.Properties-">setProp</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true" title="class or interface in java.util">Properties</a> props)</code> |
| <div class="block">Set multiple <code>KafkaConsumer</code> properties.</div> |
| </td> |
| </tr> |
| <tr id="i18" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-">setProp</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a> value)</code> |
| <div class="block">Set a <code>KafkaConsumer</code> property.</div> |
| </td> |
| </tr> |
| <tr id="i19" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setRecordTranslator-org.apache.storm.kafka.spout.Func-org.apache.storm.tuple.Fields-">setRecordTranslator</a></span>(<a href="../../../../../org/apache/storm/kafka/spout/Func.html" title="interface in org.apache.storm.kafka.spout">Func</a><org.apache.kafka.clients.consumer.ConsumerRecord<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>>> func, |
| <a href="../../../../../org/apache/storm/tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a> fields)</code> |
| <div class="block">Configure a translator with tuples to be emitted on the default stream.</div> |
| </td> |
| </tr> |
| <tr id="i20" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setRecordTranslator-org.apache.storm.kafka.spout.Func-org.apache.storm.tuple.Fields-java.lang.String-">setRecordTranslator</a></span>(<a href="../../../../../org/apache/storm/kafka/spout/Func.html" title="interface in org.apache.storm.kafka.spout">Func</a><org.apache.kafka.clients.consumer.ConsumerRecord<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>>> func, |
| <a href="../../../../../org/apache/storm/tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a> fields, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> stream)</code> |
| <div class="block">Configure a translator with tuples to be emitted to a given stream.</div> |
| </td> |
| </tr> |
| <tr id="i21" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setRecordTranslator-org.apache.storm.kafka.spout.RecordTranslator-">setRecordTranslator</a></span>(<a href="../../../../../org/apache/storm/kafka/spout/RecordTranslator.html" title="interface in org.apache.storm.kafka.spout">RecordTranslator</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> translator)</code> </td> |
| </tr> |
| <tr id="i22" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setRetry-org.apache.storm.kafka.spout.KafkaSpoutRetryService-">setRetry</a></span>(<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutRetryService.html" title="interface in org.apache.storm.kafka.spout">KafkaSpoutRetryService</a> retryService)</code> |
| <div class="block">Sets the retry service for the spout to use.</div> |
| </td> |
| </tr> |
| <tr id="i23" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setSecurityProtocol-java.lang.String-">setSecurityProtocol</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> protocol)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with “security.protocol” instead</span></div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i24" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setSSLKeystore-java.lang.String-java.lang.String-">setSSLKeystore</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> location, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> password)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with “ssl.keystore.location” and “ssl.keystore.password” instead</span></div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i25" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setSSLKeystore-java.lang.String-java.lang.String-java.lang.String-">setSSLKeystore</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> location, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> password, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> keyPassword)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with “ssl.keystore.location”, “ssl.keystore.password” and “ssl.key.password” instead</span></div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i26" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setSSLTruststore-java.lang.String-java.lang.String-">setSSLTruststore</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> location, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> password)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with “security.protocol”, “ssl.truststore.location” and “ssl.truststore.password” instead</span></div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i27" class="rowColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setTupleListener-org.apache.storm.kafka.spout.KafkaTupleListener-">setTupleListener</a></span>(<a href="../../../../../org/apache/storm/kafka/spout/KafkaTupleListener.html" title="interface in org.apache.storm.kafka.spout">KafkaTupleListener</a> tupleListener)</code> |
| <div class="block">Sets the tuple listener for the spout to use.</div> |
| </td> |
| </tr> |
| <tr id="i28" class="altColor"> |
| <td class="colFirst"><code><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setTupleTrackingEnforced-boolean-">setTupleTrackingEnforced</a></span>(boolean tupleTrackingEnforced)</code> |
| <div class="block">Specifies whether the spout should require Storm to track emitted tuples when using a <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html" title="enum in org.apache.storm.kafka.spout"><code>KafkaSpoutConfig.ProcessingGuarantee</code></a> other than <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html#AT_LEAST_ONCE"><code>KafkaSpoutConfig.ProcessingGuarantee.AT_LEAST_ONCE</code></a>.</div> |
| </td> |
| </tr> |
| <tr id="i29" class="rowColor"> |
| <td class="colFirst"><code><NV> <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,NV></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setValue-java.lang.Class-">setValue</a></span>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<NV>> clazz)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code> instead</span></div> |
| </div> |
| </td> |
| </tr> |
| <tr id="i30" class="altColor"> |
| <td class="colFirst"><code><NV> <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,NV></code></td> |
| <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setValue-org.apache.storm.kafka.spout.SerializableDeserializer-">setValue</a></span>(<a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><NV> valueDeserializer)</code> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> |
| <div class="block"><span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> instead</span></div> |
| </div> |
| </td> |
| </tr> |
| </table> |
| <ul class="blockList"> |
| <li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> |
| <!-- --> |
| </a> |
| <h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a></h3> |
| <code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#clone--" title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-" title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#finalize--" title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#getClass--" title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#hashCode--" title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notify--" title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#notifyAll--" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#toString--" title="class or interface in java.lang">toString</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait--" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait-long-" title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true#wait-long-int-" title="class or interface in java.lang">wait</a></code></li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </div> |
| <div class="details"> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <!-- ========= CONSTRUCTOR DETAIL ======== --> |
| <ul class="blockList"> |
| <li class="blockList"><a name="constructor.detail"> |
| <!-- --> |
| </a> |
| <h3>Constructor Detail</h3> |
| <a name="Builder-java.lang.String-java.lang.String...-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>Builder</h4> |
| <pre>public Builder(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>... topics)</pre> |
| </li> |
| </ul> |
| <a name="Builder-java.lang.String-java.util.Collection-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>Builder</h4> |
| <pre>public Builder(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> topics)</pre> |
| </li> |
| </ul> |
| <a name="Builder-java.lang.String-java.util.regex.Pattern-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>Builder</h4> |
| <pre>public Builder(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/util/regex/Pattern.html?is-external=true" title="class or interface in java.util.regex">Pattern</a> topics)</pre> |
| </li> |
| </ul> |
| <a name="Builder-java.lang.String-org.apache.storm.kafka.spout.SerializableDeserializer-org.apache.storm.kafka.spout.SerializableDeserializer-java.lang.String...-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>Builder</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public Builder(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>> keyDes, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> valDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>... topics)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <code>#Builder(java.lang.String, java.lang.String...)</code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </li> |
| </ul> |
| <a name="Builder-java.lang.String-org.apache.storm.kafka.spout.SerializableDeserializer-org.apache.storm.kafka.spout.SerializableDeserializer-java.util.Collection-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>Builder</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public Builder(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>> keyDes, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> valDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> topics)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <code>#Builder(java.lang.String, java.util.Collection) </code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </li> |
| </ul> |
| <a name="Builder-java.lang.String-org.apache.storm.kafka.spout.SerializableDeserializer-org.apache.storm.kafka.spout.SerializableDeserializer-java.util.regex.Pattern-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>Builder</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public Builder(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>> keyDes, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> valDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/util/regex/Pattern.html?is-external=true" title="class or interface in java.util.regex">Pattern</a> topics)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <code>#Builder(java.lang.String, java.util.regex.Pattern) </code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </li> |
| </ul> |
| <a name="Builder-java.lang.String-org.apache.storm.kafka.spout.SerializableDeserializer-org.apache.storm.kafka.spout.SerializableDeserializer-org.apache.storm.kafka.spout.Subscription-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>Builder</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public Builder(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>> keyDes, |
| <a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> valDes, |
| <a href="../../../../../org/apache/storm/kafka/spout/Subscription.html" title="class in org.apache.storm.kafka.spout">Subscription</a> subscription)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <code>#Builder(java.lang.String, org.apache.storm.kafka.spout.Subscription) </code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </li> |
| </ul> |
| <a name="Builder-java.lang.String-java.lang.Class-java.lang.Class-java.lang.String...-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>Builder</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public Builder(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>>> keyDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>>> valDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>... topics)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <code>#Builder(java.lang.String, java.lang.String...)</code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </li> |
| </ul> |
| <a name="Builder-java.lang.String-java.lang.Class-java.lang.Class-java.util.Collection-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>Builder</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public Builder(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>>> keyDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>>> valDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true" title="class or interface in java.util">Collection</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>> topics)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <code>#Builder(java.lang.String, java.util.Collection) </code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </li> |
| </ul> |
| <a name="Builder-java.lang.String-java.lang.Class-java.lang.Class-java.util.regex.Pattern-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>Builder</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public Builder(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>>> keyDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>>> valDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/util/regex/Pattern.html?is-external=true" title="class or interface in java.util.regex">Pattern</a> topics)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <code>#Builder(java.lang.String, java.util.regex.Pattern) </code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </li> |
| </ul> |
| <a name="Builder-java.lang.String-java.lang.Class-java.lang.Class-org.apache.storm.kafka.spout.Subscription-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>Builder</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public Builder(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>>> keyDes, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>>> valDes, |
| <a href="../../../../../org/apache/storm/kafka/spout/Subscription.html" title="class in org.apache.storm.kafka.spout">Subscription</a> subscription)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <code>#Builder(java.lang.String, org.apache.storm.kafka.spout.Subscription) </code> instead, and set the deserializer with <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a>, <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> and <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code></span></div> |
| </li> |
| </ul> |
| <a name="Builder-java.lang.String-org.apache.storm.kafka.spout.Subscription-"> |
| <!-- --> |
| </a> |
| <ul class="blockListLast"> |
| <li class="blockList"> |
| <h4>Builder</h4> |
| <pre>public Builder(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> bootstrapServers, |
| <a href="../../../../../org/apache/storm/kafka/spout/Subscription.html" title="class in org.apache.storm.kafka.spout">Subscription</a> subscription)</pre> |
| <div class="block"><p>Create a KafkaSpoutConfig builder with default property values and no key/value deserializers.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>bootstrapServers</code> - The bootstrap servers the consumer will use</dd> |
| <dd><code>subscription</code> - The subscription defining which topics and partitions each spout instance will read.</dd> |
| </dl> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| <!-- ============ METHOD DETAIL ========== --> |
| <ul class="blockList"> |
| <li class="blockList"><a name="method.detail"> |
| <!-- --> |
| </a> |
| <h3>Method Detail</h3> |
| <a name="setKey-org.apache.storm.kafka.spout.SerializableDeserializer-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setKey</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <NK> <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><NK,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setKey(<a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><NK> keyDeserializer)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> instead</span></div> |
| <div class="block"><p>Specifying this key deserializer overrides the property key.deserializer. If you have set a custom RecordTranslator before calling this it may result in class cast exceptions at runtime.</p></div> |
| </li> |
| </ul> |
| <a name="setKey-java.lang.Class-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setKey</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <NK> <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><NK,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setKey(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<NK>> clazz)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code> instead</span></div> |
| <div class="block"><p>Specify a class that can be instantiated to create a key.deserializer This is the same as setting key.deserializer, but overrides it. If you have set a custom RecordTranslator before calling this it may result in class cast exceptions at runtime.</p></div> |
| </li> |
| </ul> |
| <a name="setValue-org.apache.storm.kafka.spout.SerializableDeserializer-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setValue</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <NV> <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,NV> setValue(<a href="../../../../../org/apache/storm/kafka/spout/SerializableDeserializer.html" title="interface in org.apache.storm.kafka.spout">SerializableDeserializer</a><NV> valueDeserializer)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG</code> instead</span></div> |
| <div class="block"><p>Specifying this value deserializer overrides the property value.deserializer. If you have set a custom RecordTranslator before calling this it may result in class cast exceptions at runtime.</p></div> |
| </li> |
| </ul> |
| <a name="setValue-java.lang.Class-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setValue</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <NV> <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,NV> setValue(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Class.html?is-external=true" title="class or interface in java.lang">Class</a><? extends org.apache.kafka.common.serialization.Deserializer<NV>> clazz)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG</code> instead</span></div> |
| <div class="block"><p>Specify a class that can be instantiated to create a value.deserializer This is the same as setting value.deserializer, but overrides it. If you have set a custom RecordTranslator before calling this it may result in class cast exceptions at runtime.</p></div> |
| </li> |
| </ul> |
| <a name="setProp-java.lang.String-java.lang.Object-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setProp</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setProp(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> key, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a> value)</pre> |
| <div class="block"><p>Set a <code>KafkaConsumer</code> property.</p></div> |
| </li> |
| </ul> |
| <a name="setProp-java.util.Map-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setProp</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setProp(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true" title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>> props)</pre> |
| <div class="block"><p>Set multiple <code>KafkaConsumer</code> properties.</p></div> |
| </li> |
| </ul> |
| <a name="setProp-java.util.Properties-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setProp</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setProp(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/Properties.html?is-external=true" title="class or interface in java.util">Properties</a> props)</pre> |
| <div class="block"><p>Set multiple <code>KafkaConsumer</code> properties.</p></div> |
| </li> |
| </ul> |
| <a name="setGroupId-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setGroupId</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setGroupId(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> id)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.GROUP_ID_CONFIG</code> instead</span></div> |
| <div class="block"><p>Set the group.id for the consumers</p></div> |
| </li> |
| </ul> |
| <a name="setBootstrapServers-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setBootstrapServers</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setBootstrapServers(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> servers)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG</code> instead</span></div> |
| <div class="block"><p>reset the bootstrap servers for the Consumer</p></div> |
| </li> |
| </ul> |
| <a name="setFetchMinBytes-int-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setFetchMinBytes</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setFetchMinBytes(int bytes)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.FETCH_MIN_BYTES_CONFIG</code> instead</span></div> |
| <div class="block"><p>The minimum amount of data the broker should return for a fetch request.</p></div> |
| </li> |
| </ul> |
| <a name="setMaxPartitionFectchBytes-int-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setMaxPartitionFectchBytes</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setMaxPartitionFectchBytes(int bytes)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.MAX_PARTITION_FETCH_BYTES_CONFIG</code> instead</span></div> |
| <div class="block"><p>The maximum amount of data per-partition the broker will return.</p></div> |
| </li> |
| </ul> |
| <a name="setMaxPollRecords-int-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setMaxPollRecords</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setMaxPollRecords(int records)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with <code>ConsumerConfig.MAX_POLL_RECORDS_CONFIG</code> instead</span></div> |
| <div class="block"><p>The maximum number of records a poll will return.</p></div> |
| </li> |
| </ul> |
| <a name="setSSLKeystore-java.lang.String-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setSSLKeystore</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setSSLKeystore(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> location, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> password)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with “ssl.keystore.location” and “ssl.keystore.password” instead</span></div> |
| <div class="block"><p>Configure the SSL Keystore for mutual authentication</p></div> |
| </li> |
| </ul> |
| <a name="setSSLKeystore-java.lang.String-java.lang.String-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setSSLKeystore</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setSSLKeystore(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> location, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> password, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> keyPassword)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with “ssl.keystore.location”, “ssl.keystore.password” and “ssl.key.password” instead</span></div> |
| <div class="block"><p>Configure the SSL Keystore for mutual authentication</p></div> |
| </li> |
| </ul> |
| <a name="setSSLTruststore-java.lang.String-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setSSLTruststore</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setSSLTruststore(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> location, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> password)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with “security.protocol”, “ssl.truststore.location” and “ssl.truststore.password” instead</span></div> |
| <div class="block"><p>Configure the SSL Truststore to authenticate with the brokers</p></div> |
| </li> |
| </ul> |
| <a name="setSecurityProtocol-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setSecurityProtocol</h4> |
| <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true" title="class or interface in java.lang">@Deprecated</a> |
| public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setSecurityProtocol(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> protocol)</pre> |
| <div class="block"><span class="deprecatedLabel">Deprecated.</span> <span class="deprecationComment">Please use <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html#setProp-java.lang.String-java.lang.Object-"><code>setProp(java.lang.String, java.lang.Object)</code></a> with “security.protocol” instead</span></div> |
| <div class="block"><p>Protocol used to communicate with brokers. Valid values are: PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL.</p></div> |
| </li> |
| </ul> |
| <a name="setPollTimeoutMs-long-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setPollTimeoutMs</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setPollTimeoutMs(long pollTimeoutMs)</pre> |
| <div class="block"><p>Specifies the time, in milliseconds, spent waiting in poll if data is not available. Default is 2s.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>pollTimeoutMs</code> - time in ms</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setOffsetCommitPeriodMs-long-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setOffsetCommitPeriodMs</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setOffsetCommitPeriodMs(long offsetCommitPeriodMs)</pre> |
| <div class="block"><p>Specifies the period, in milliseconds, the offset commit task is periodically called. Default is 15s.</p><p><p>This setting only has an effect if the configured <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html" title="enum in org.apache.storm.kafka.spout"><code>KafkaSpoutConfig.ProcessingGuarantee</code></a> is <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html#AT_LEAST_ONCE"><code>KafkaSpoutConfig.ProcessingGuarantee.AT_LEAST_ONCE</code></a> or <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html#NO_GUARANTEE"><code>KafkaSpoutConfig.ProcessingGuarantee.NO_GUARANTEE</code></a>.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>offsetCommitPeriodMs</code> - time in ms</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setMaxUncommittedOffsets-int-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setMaxUncommittedOffsets</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setMaxUncommittedOffsets(int maxUncommittedOffsets)</pre> |
| <div class="block"><p>Defines the max number of polled offsets (records) that can be pending commit, before another poll can take place. Once this limit is reached, no more offsets (records) can be polled until the next successful commit(s) sets the number of pending offsets below the threshold. The default is <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.html#DEFAULT_MAX_UNCOMMITTED_OFFSETS"><code>KafkaSpoutConfig.DEFAULT_MAX_UNCOMMITTED_OFFSETS</code></a>. This limit is per partition and may in some cases be exceeded, but each partition cannot exceed this limit by more than maxPollRecords - 1.</p><p><p>This setting only has an effect if the configured <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html" title="enum in org.apache.storm.kafka.spout"><code>KafkaSpoutConfig.ProcessingGuarantee</code></a> is <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html#AT_LEAST_ONCE"><code>KafkaSpoutConfig.ProcessingGuarantee.AT_LEAST_ONCE</code></a>.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>maxUncommittedOffsets</code> - max number of records that can be be pending commit</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setFirstPollOffsetStrategy-org.apache.storm.kafka.spout.KafkaSpoutConfig.FirstPollOffsetStrategy-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setFirstPollOffsetStrategy</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setFirstPollOffsetStrategy(<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.FirstPollOffsetStrategy.html" title="enum in org.apache.storm.kafka.spout">KafkaSpoutConfig.FirstPollOffsetStrategy</a> firstPollOffsetStrategy)</pre> |
| <div class="block"><p>Sets the offset used by the Kafka spout in the first poll to Kafka broker upon process start. Please refer to to the documentation in <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.FirstPollOffsetStrategy.html" title="enum in org.apache.storm.kafka.spout"><code>KafkaSpoutConfig.FirstPollOffsetStrategy</code></a></p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>firstPollOffsetStrategy</code> - Offset used by Kafka spout first poll</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setRetry-org.apache.storm.kafka.spout.KafkaSpoutRetryService-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setRetry</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setRetry(<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutRetryService.html" title="interface in org.apache.storm.kafka.spout">KafkaSpoutRetryService</a> retryService)</pre> |
| <div class="block"><p>Sets the retry service for the spout to use.</p><p><p>This setting only has an effect if the configured <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html" title="enum in org.apache.storm.kafka.spout"><code>KafkaSpoutConfig.ProcessingGuarantee</code></a> is <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html#AT_LEAST_ONCE"><code>KafkaSpoutConfig.ProcessingGuarantee.AT_LEAST_ONCE</code></a>.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>retryService</code> - the new retry service</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>the builder (this).</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setTupleListener-org.apache.storm.kafka.spout.KafkaTupleListener-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setTupleListener</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setTupleListener(<a href="../../../../../org/apache/storm/kafka/spout/KafkaTupleListener.html" title="interface in org.apache.storm.kafka.spout">KafkaTupleListener</a> tupleListener)</pre> |
| <div class="block"><p>Sets the tuple listener for the spout to use.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>tupleListener</code> - the tuple listener</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>the builder (this).</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setRecordTranslator-org.apache.storm.kafka.spout.RecordTranslator-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setRecordTranslator</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setRecordTranslator(<a href="../../../../../org/apache/storm/kafka/spout/RecordTranslator.html" title="interface in org.apache.storm.kafka.spout">RecordTranslator</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> translator)</pre> |
| </li> |
| </ul> |
| <a name="setRecordTranslator-org.apache.storm.kafka.spout.Func-org.apache.storm.tuple.Fields-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setRecordTranslator</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setRecordTranslator(<a href="../../../../../org/apache/storm/kafka/spout/Func.html" title="interface in org.apache.storm.kafka.spout">Func</a><org.apache.kafka.clients.consumer.ConsumerRecord<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>>> func, |
| <a href="../../../../../org/apache/storm/tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a> fields)</pre> |
| <div class="block"><p>Configure a translator with tuples to be emitted on the default stream.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>func</code> - extracts and turns a Kafka ConsumerRecord into a list of objects to be emitted</dd> |
| <dd><code>fields</code> - the names of the fields extracted</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>this to be able to chain configuration</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setRecordTranslator-org.apache.storm.kafka.spout.Func-org.apache.storm.tuple.Fields-java.lang.String-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setRecordTranslator</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setRecordTranslator(<a href="../../../../../org/apache/storm/kafka/spout/Func.html" title="interface in org.apache.storm.kafka.spout">Func</a><org.apache.kafka.clients.consumer.ConsumerRecord<<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Object.html?is-external=true" title="class or interface in java.lang">Object</a>>> func, |
| <a href="../../../../../org/apache/storm/tuple/Fields.html" title="class in org.apache.storm.tuple">Fields</a> fields, |
| <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> stream)</pre> |
| <div class="block"><p>Configure a translator with tuples to be emitted to a given stream.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>func</code> - extracts and turns a Kafka ConsumerRecord into a list of objects to be emitted</dd> |
| <dd><code>fields</code> - the names of the fields extracted</dd> |
| <dd><code>stream</code> - the stream to emit the tuples on</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>this to be able to chain configuration</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setPartitionRefreshPeriodMs-long-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setPartitionRefreshPeriodMs</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setPartitionRefreshPeriodMs(long partitionRefreshPeriodMs)</pre> |
| <div class="block"><p>Sets partition refresh period in milliseconds. This is how often kafka will be polled to check for new topics and/or new partitions. This is mostly for Subscription implementations that manually assign partitions. NamedSubscription and PatternSubscription rely on kafka to handle this instead.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>partitionRefreshPeriodMs</code> - time in milliseconds</dd> |
| <dt><span class="returnLabel">Returns:</span></dt> |
| <dd>the builder (this)</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setEmitNullTuples-boolean-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setEmitNullTuples</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setEmitNullTuples(boolean emitNullTuples)</pre> |
| <div class="block"><p>Specifies if the spout should emit null tuples to the component downstream, or rather not emit and directly ack them. By default this parameter is set to false, which means that null tuples are not emitted.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>emitNullTuples</code> - sets if null tuples should or not be emitted downstream</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setProcessingGuarantee-org.apache.storm.kafka.spout.KafkaSpoutConfig.ProcessingGuarantee-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setProcessingGuarantee</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setProcessingGuarantee(<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html" title="enum in org.apache.storm.kafka.spout">KafkaSpoutConfig.ProcessingGuarantee</a> processingGuarantee)</pre> |
| <div class="block"><p>Specifies which processing guarantee the spout should offer. Refer to the documentation for <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html" title="enum in org.apache.storm.kafka.spout"><code>KafkaSpoutConfig.ProcessingGuarantee</code></a>.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>processingGuarantee</code> - The processing guarantee the spout should offer.</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setTupleTrackingEnforced-boolean-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setTupleTrackingEnforced</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setTupleTrackingEnforced(boolean tupleTrackingEnforced)</pre> |
| <div class="block"><p>Specifies whether the spout should require Storm to track emitted tuples when using a <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html" title="enum in org.apache.storm.kafka.spout"><code>KafkaSpoutConfig.ProcessingGuarantee</code></a> other than <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.ProcessingGuarantee.html#AT_LEAST_ONCE"><code>KafkaSpoutConfig.ProcessingGuarantee.AT_LEAST_ONCE</code></a>. The spout will always track emitted tuples when offering at-least-once guarantees regardless of this setting. This setting is false by default.</p><p><p>Enabling tracking can be useful even in cases where reliability is not a concern, because it allows <a href="../../../../../org/apache/storm/Config.html#TOPOLOGY_MAX_SPOUT_PENDING"><code>Config.TOPOLOGY_MAX_SPOUT_PENDING</code></a> to have an effect, and enables some spout metrics (e.g. complete-latency) that would otherwise be disabled.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>tupleTrackingEnforced</code> - true if Storm should track emitted tuples, false otherwise</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="setMetricsTimeBucketSizeInSecs-int-"> |
| <!-- --> |
| </a> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>setMetricsTimeBucketSizeInSecs</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig.Builder</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> setMetricsTimeBucketSizeInSecs(int metricsTimeBucketSizeInSecs)</pre> |
| <div class="block"><p>The time period that metrics data in bucketed into.</p></div> |
| <dl> |
| <dt><span class="paramLabel">Parameters:</span></dt> |
| <dd><code>metricsTimeBucketSizeInSecs</code> - time in seconds</dd> |
| </dl> |
| </li> |
| </ul> |
| <a name="build--"> |
| <!-- --> |
| </a> |
| <ul class="blockListLast"> |
| <li class="blockList"> |
| <h4>build</h4> |
| <pre>public <a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.html" title="class in org.apache.storm.kafka.spout">KafkaSpoutConfig</a><<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">K</a>,<a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" title="type parameter in KafkaSpoutConfig.Builder">V</a>> build()</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </div> |
| </div> |
| <!-- ========= END OF CLASS DATA ========= --> |
| <!-- ======= START OF BOTTOM NAVBAR ====== --> |
| <div class="bottomNav"><a name="navbar.bottom"> |
| <!-- --> |
| </a> |
| <div class="skipNav"><a href="#skip.navbar.bottom" title="Skip navigation links">Skip navigation links</a></div> |
| <a name="navbar.bottom.firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="../../../../../overview-summary.html">Overview</a></li> |
| <li><a href="package-summary.html">Package</a></li> |
| <li class="navBarCell1Rev">Class</li> |
| <li><a href="class-use/KafkaSpoutConfig.Builder.html">Use</a></li> |
| <li><a href="package-tree.html">Tree</a></li> |
| <li><a href="../../../../../deprecated-list.html">Deprecated</a></li> |
| <li><a href="../../../../../index-all.html">Index</a></li> |
| <li><a href="../../../../../help-doc.html">Help</a></li> |
| </ul> |
| <div class="aboutLanguage"><script type="text/javascript" src="../../../../../highlight.pack.js"></script> |
| <script type="text/javascript"><!-- |
| hljs.initHighlightingOnLoad(); |
| //--></script></div> |
| </div> |
| <div class="subNav"> |
| <ul class="navList"> |
| <li><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.html" title="class in org.apache.storm.kafka.spout"><span class="typeNameLink">Prev Class</span></a></li> |
| <li><a href="../../../../../org/apache/storm/kafka/spout/KafkaSpoutConfig.FirstPollOffsetStrategy.html" title="enum in org.apache.storm.kafka.spout"><span class="typeNameLink">Next Class</span></a></li> |
| </ul> |
| <ul class="navList"> |
| <li><a href="../../../../../index.html?org/apache/storm/kafka/spout/KafkaSpoutConfig.Builder.html" target="_top">Frames</a></li> |
| <li><a href="KafkaSpoutConfig.Builder.html" target="_top">No Frames</a></li> |
| </ul> |
| <ul class="navList" id="allclasses_navbar_bottom"> |
| <li><a href="../../../../../allclasses-noframe.html">All Classes</a></li> |
| </ul> |
| <div> |
| <script type="text/javascript"><!-- |
| allClassesLink = document.getElementById("allclasses_navbar_bottom"); |
| if(window==top) { |
| allClassesLink.style.display = "block"; |
| } |
| else { |
| allClassesLink.style.display = "none"; |
| } |
| //--> |
| </script> |
| </div> |
| <div> |
| <ul class="subNavList"> |
| <li>Summary: </li> |
| <li>Nested | </li> |
| <li>Field | </li> |
| <li><a href="#constructor.summary">Constr</a> | </li> |
| <li><a href="#method.summary">Method</a></li> |
| </ul> |
| <ul class="subNavList"> |
| <li>Detail: </li> |
| <li>Field | </li> |
| <li><a href="#constructor.detail">Constr</a> | </li> |
| <li><a href="#method.detail">Method</a></li> |
| </ul> |
| </div> |
| <a name="skip.navbar.bottom"> |
| <!-- --> |
| </a></div> |
| <!-- ======== END OF BOTTOM NAVBAR ======= --> |
| <p class="legalCopy"><small>Copyright © 2018 <a href="http://www.apache.org/">The Apache Software Foundation</a>. All Rights Reserved.</small></p> |
| </body> |
| </html> |
