Revert change for offset beginning

Author: Spencer Sortman

ncdssdk/docs/build/.doctrees/BasicKafkaConsumer.doctree

@@ -186,7 +186,7 @@ <h3>Navigation</h3>
     </div>
     <div class="footer" role="contentinfo">
         &#169; Copyright 2021, Nasdaq.
-      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.2.
+      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.0.
     </div>
   </body>
 </html>

ncdssdk/docs/build/.doctrees/KafkaAvroConsumer.doctree

@@ -159,7 +159,7 @@ <h3>Navigation</h3>
     </div>
     <div class="footer" role="contentinfo">
         &#169; Copyright 2021, Nasdaq.
-      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.2.
+      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.0.
     </div>
   </body>
 </html>

ncdssdk/docs/build/.doctrees/NasdaqKafkaAvroConsumer.doctree

@@ -190,7 +190,7 @@ <h3>Navigation</h3>
     </div>
     <div class="footer" role="contentinfo">
         &#169; Copyright 2021, Nasdaq.
-      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.2.
+      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.0.
     </div>
   </body>
 </html>

ncdssdk/docs/build/.doctrees/consumer.doctree

@@ -276,7 +276,7 @@ var Search = {
           setTimeout(function() {
             displayNextItem();
           }, 5);
-        } else if (DOCUMENTATION_OPTIONS.HAS_SOURCE) {
+        } else {
           $.ajax({url: requestUrl,
                   dataType: "text",
                   complete: function(jqxhr, textstatus) {
@@ -289,12 +289,6 @@ var Search = {
                       displayNextItem();
                     }, 5);
                   }});
-        } else {
-          // no source available, just display title
-          Search.output.append(listItem);
-          setTimeout(function() {
-            displayNextItem();
-          }, 5);
         }
       }
       // search finished, update title and status message

ncdssdk/docs/build/.doctrees/environment.pickle

@@ -110,7 +110,7 @@ <h3>Navigation</h3>
     </div>
     <div class="footer" role="contentinfo">
         &#169; Copyright 2021, Nasdaq.
-      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.2.
+      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.0.
     </div>
   </body>
 </html>

ncdssdk/docs/build/.doctrees/index.doctree

@@ -352,7 +352,7 @@ <h3>Navigation</h3>
     </div>
     <div class="footer" role="contentinfo">
         &#169; Copyright 2021, Nasdaq.
-      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.2.
+      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.0.
     </div>
   </body>
 </html>

ncdssdk/docs/build/.doctrees/internal.doctree

@@ -116,7 +116,7 @@ <h3>Navigation</h3>
     </div>
     <div class="footer" role="contentinfo">
         &#169; Copyright 2021, Nasdaq.
-      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.2.
+      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.0.
     </div>
   </body>
 </html>

ncdssdk/docs/build/.doctrees/ncdsclient.doctree

@@ -117,7 +117,7 @@ <h3>Navigation</h3>
     </div>
     <div class="footer" role="contentinfo">
         &#169; Copyright 2021, Nasdaq.
-      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.2.
+      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.0.
     </div>
   </body>
 </html>

ncdssdk/docs/build/.doctrees/utils.doctree

@@ -150,8 +150,8 @@ <h3>Navigation</h3>
 <span class="sig-name descname"><span class="pre">ncds_kafka_consumer</span></span><span class="sig-paren">(</span><em class="sig-param"><span class="n"><span class="pre">topic</span></span></em>, <em class="sig-param"><span class="n"><span class="pre">timestamp</span></span><span class="o"><span class="pre">=</span></span><span class="default_value"><span class="pre">None</span></span></em><span class="sig-paren">)</span><a class="headerlink" href="#ncdssdk.src.main.python.ncdsclient.NCDSClient.NCDSClient.ncds_kafka_consumer" title="Permalink to this definition">¶</a></dt>
 <dd><p>Retrieves the apache kafka consumer. If the timestamp is not set, the consumer will
 start consuming at midnight of this day if auto.offset.reset in the kafka_cfg is set to
-earliest. If auto.offset.reset is not set to earliest, the consumer will start consuming
-at the smallest offset.</p>
+earliest. If auto.offset.reset is set to some variation of ‘latest’, the consumer will
+start consuming at the end offset.</p>
 <dl class="field-list simple">
 <dt class="field-odd">Parameters</dt>
 <dd class="field-odd"><ul class="simple">
@@ -247,7 +247,7 @@ <h3>Navigation</h3>
     </div>
     <div class="footer" role="contentinfo">
         &#169; Copyright 2021, Nasdaq.
-      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.2.
+      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.0.
     </div>
   </body>
 </html>

ncdssdk/docs/build/BasicKafkaConsumer.html

@@ -148,7 +148,7 @@ <h3>Navigation</h3>
     </div>
     <div class="footer" role="contentinfo">
         &#169; Copyright 2021, Nasdaq.
-      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.2.
+      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.0.
     </div>
   </body>
 </html>

ncdssdk/docs/build/KafkaAvroConsumer.html

@@ -98,7 +98,7 @@ <h3>Navigation</h3>
     </div>
     <div class="footer" role="contentinfo">
         &#169; Copyright 2021, Nasdaq.
-      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.2.
+      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.0.
     </div>
   </body>
 </html>

ncdssdk/docs/build/NasdaqKafkaAvroConsumer.html

@@ -183,7 +183,7 @@ <h3>Navigation</h3>
     </div>
     <div class="footer" role="contentinfo">
         &#169; Copyright 2021, Nasdaq.
-      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.2.
+      Created using <a href="https://www.sphinx-doc.org/">Sphinx</a> 4.1.0.
     </div>
   </body>
 </html>

ncdssdk/docs/build/_static/searchtools.js

@@ -76,8 +76,8 @@ def ncds_kafka_consumer(self, topic, timestamp=None):
         """
         Retrieves the apache kafka consumer. If the timestamp is not set, the consumer will
         start consuming at midnight of this day if auto.offset.reset in the kafka_cfg is set to
-        earliest. If auto.offset.reset is not set to earliest, the consumer will start consuming
-        at the smallest offset.
+        earliest. If auto.offset.reset is set to some variation of 'latest', the consumer will
+        start consuming at the end offset.
 
         Args:
             topic (string): Topic/Stream name

ncdssdk/docs/build/consumer.html

@@ -78,7 +78,7 @@ def get_kafka_consumer(self, stream_name, timestamp=None):
                 "Kafka Schema not found for stream: " + stream_name)
         kafka_consumer = self.get_consumer(kafka_schema, stream_name)
         topic_partition = TopicPartition(
-            topic=stream_name + ".stream", partition=0, offset=OFFSET_BEGINNING)
+            topic=stream_name + ".stream", partition=0, offset=OFFSET_END)
         self.logger.debug(
             f"Assigning kafka consumer to topic partition: {topic_partition}")
         kafka_consumer.assign([topic_partition])