|
1 | 1 | (ns ^{:doc "Clojure interface for Kafka Consumer API.
|
2 | 2 | For complete JavaDocs, see:
|
3 |
| - http://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/package-summary.html"} |
| 3 | + https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/package-summary.html"} |
4 | 4 | clj-kafka-x.consumers.simple
|
5 | 5 | (:require [clj-kafka-x.data :refer :all]
|
6 | 6 | [clj-kafka-x.impl.helpers :refer :all])
|
|
20 | 20 | "Takes a map of config options and returns a `KafkaConsumer` for consuming records from Kafka.
|
21 | 21 |
|
22 | 22 | NOTE `KafkaConsumer` instances are NOT thread-safe, see
|
23 |
| - https://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#multithreaded |
| 23 | + https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#multithreaded |
24 | 24 |
|
25 |
| - For more information and available conifg options, |
26 |
| - see: http://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html |
| 25 | + For more information and available config options, |
| 26 | + see: https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html |
27 | 27 | http://kafka.apache.org/documentation.html#newconsumerconfigs
|
28 | 28 |
|
29 | 29 | Usage:
|
|
90 | 90 | ;; => nil
|
91 | 91 |
|
92 | 92 | For more in-depth information
|
93 |
| - http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.List) |
94 |
| - http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.List,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener) |
95 |
| - http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.regex.Pattern,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener) |
96 |
| - http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.List) |
| 93 | + https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection) |
| 94 | + http://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.Collection,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener) |
| 95 | + http://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#subscribe(java.util.regex.Pattern,%20org.apache.kafka.clients.consumer.ConsumerRebalanceListener) |
| 96 | + https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#assign(java.util.Collection) |
97 | 97 | "
|
98 | 98 | [^Consumer consumer topics & {:keys [assigned-callback revoked-callback]
|
99 | 99 | :or {assigned-callback (fn [_])
|
|
315 | 315 | (.commitSync consumer tp-om-map))))
|
316 | 316 |
|
317 | 317 |
|
318 |
| -(defn last-committed-offset |
| 318 | +(defn ^:deprecated last-committed-offset |
319 | 319 | "Gets the last committed offset for the partition of a topic.
|
320 | 320 | NOTE This function is a blocking I/O operation.
|
321 | 321 |
|
|
337 | 337 | "Get metadata about ALL partitions for ALL topics that the user is authorized to view.
|
338 | 338 | NOTE This function is a blocking I/O operation.
|
339 | 339 |
|
340 |
| - See http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#listTopics() |
| 340 | + See https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#listTopics() |
341 | 341 |
|
342 | 342 | Usage :
|
343 | 343 |
|
|
372 | 372 | "Get metadata about all partitions for a particular topic.
|
373 | 373 | NOTE This function is a blocking I/O operation.
|
374 | 374 |
|
375 |
| - See http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#partitionsFor(java.lang.String) |
| 375 | + See https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#partitionsFor(java.lang.String) |
376 | 376 |
|
377 | 377 | Usage :
|
378 | 378 |
|
|
400 | 400 | (defn pause
|
401 | 401 | "Stops messages being consumed from the given partitions.
|
402 | 402 | This takes effect on the next call on the messages function
|
403 |
| - See http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(org.apache.kafka.common.TopicPartition...) |
| 403 | + See https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#pause(java.util.Collection) |
404 | 404 |
|
405 | 405 | Usage:
|
406 | 406 |
|
|
416 | 416 | (defn resume
|
417 | 417 | "Resumes messages being consumed from the given partitions.
|
418 | 418 | This takes effect on the next call on the messages function
|
419 |
| - See http://kafka.apache.org/0100/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#resume(org.apache.kafka.common.TopicPartition...) |
| 419 | + See https://kafka.apache.org/34/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#resume(java.util.Collection) |
420 | 420 |
|
421 | 421 | Usage:
|
422 | 422 |
|
|
0 commit comments