update afficial doc references

Author: source-c

src/clj_kafka_x/consumers/simple.clj

@@ -1,6 +1,6 @@
 (ns ^{:doc "Clojure interface for Kafka Consumer API.
             For complete JavaDocs, see:
-            http://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/package-summary.html"}
+            https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/package-summary.html"}
   clj-kafka-x.consumers.simple
   (:require [clj-kafka-x.data :refer :all]
             [clj-kafka-x.impl.helpers :refer :all])
@@ -20,10 +20,10 @@
   "Takes a map of config options and returns a `KafkaConsumer` for consuming records from Kafka.
 
   NOTE `KafkaConsumer` instances are NOT thread-safe, see
-  https://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#multithreaded
+  https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#multithreaded
 
-  For more information and available conifg options,
-  see: http://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html
+  For more information and available config options,
+  see: https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
        http://kafka.apache.org/documentation.html#newconsumerconfigs
 
   Usage:
@@ -90,10 +90,10 @@
   ;; => nil
 
   For more in-depth information
-  http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.List)
-  http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.List,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)
-  http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.regex.Pattern,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)
-  http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.List)
+  https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection)
+  http://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)
+  http://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.regex.Pattern,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener)
+  https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.Collection)
   "
   [^Consumer consumer topics & {:keys [assigned-callback revoked-callback]
                                 :or   {assigned-callback (fn [_])
@@ -315,7 +315,7 @@
      (.commitSync consumer tp-om-map))))
 
 
-(defn last-committed-offset
+(defn ^:deprecated last-committed-offset
   "Gets the last committed offset for the partition of a topic.
    NOTE This function is a blocking I/O operation.
 
@@ -337,7 +337,7 @@
   "Get metadata about ALL partitions for ALL topics that the user is authorized to view.
    NOTE This function is a blocking I/O operation.
 
-   See http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#listTopics()
+   See https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#listTopics()
 
   Usage :
 
@@ -372,7 +372,7 @@
   "Get metadata about all partitions for a particular topic.
    NOTE This function is a blocking I/O operation.
 
-   See http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#partitionsFor(java.lang.String)
+   See https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#partitionsFor(java.lang.String)
 
   Usage :
 
@@ -400,7 +400,7 @@
 (defn pause
   "Stops messages being consumed from the given partitions.
    This takes effect on the next call on the messages function
-   See http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(org.apache.kafka.common.TopicPartition...)
+   See https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(java.util.Collection)
 
   Usage:
 
@@ -416,7 +416,7 @@
 (defn resume
   "Resumes messages being consumed from the given partitions.
    This takes effect on the next call on the messages function
-   See http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#resume(org.apache.kafka.common.TopicPartition...)
+   See https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#resume(java.util.Collection)
 
   Usage:
 

src/clj_kafka_x/producer.clj

@@ -1,6 +1,6 @@
 (ns ^{:doc "Clojure interface for Kafka Producer API. For
   complete JavaDocs, see:
-  http://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/producer/package-summary.html"}
+  https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/producer/package-summary.html"}
   clj-kafka-x.producer
   (:refer-clojure :exclude [send flush])
   (:require [clj-kafka-x.data :refer :all]
@@ -32,8 +32,8 @@
   NOTE `KafkaProducer` instances are thread-safe and should generally be shared for best performance.
 
   For more information and available config options,
-  see: http://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html
-       http://kafka.apache.org/documentation.html#producerconfigs
+  see: https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html
+       https://kafka.apache.org/documentation.html#producerconfigs
 
 
   Usage:
@@ -75,7 +75,7 @@
   Callback should be a fn of two arguments, a map as above, and an
   exception. Exception will be nil if operation succeeded.
 
-  See: http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#send(org.apache.kafka.clients.producer.ProducerRecord)
+  See: https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#send(org.apache.kafka.clients.producer.ProducerRecord)
 
   Usage:
 
@@ -103,7 +103,7 @@
      (map-future-val fut to-clojure))))
 
 (defn flush
-  "See: http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#flush()"
+  "See: https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#flush()"
   [^Producer producer]
   (.flush producer))
 
@@ -112,8 +112,8 @@
 
   See:
 
-  - http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#close()
-  - http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#close(long,%20java.util.concurrent.TimeUnit)"
+  - https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#close()
+  - https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#close(java.time.Duration)"
   ([^Producer producer]
    (.close producer))
   ([^Producer producer timeout-ms]