franzy.clients.consumer.protocols — ymilky/franzy 0.0.1

AutomaticPartitionAssignor clj protocol

Automatically assigns topic partitions to consumers.

clear-subscriptions! clj

(clear-subscriptions! this)

partition-subscriptions clj

(partition-subscriptions this)

subscribe-to-partitions! clj

(subscribe-to-partitions! this topics)

(subscribe-to-partitions! this topics opts)

FranzPartitionAssignor clj protocol

Protocol used for implementors that need a specialized algorithm for assigning partitions to Kafka. Example strategies include by range or round-robin. See franzy.clients.consumer.partitioners examples.

assign-partition! clj

(assign-partition! this partitions-per-topic subscriptions)

partition-assigned clj

(partition-assigned this assignment)

partition-assignor-name clj

(partition-assignor-name this)

partition-subscription clj

(partition-subscription this topics)

FranzyConsumer clj protocol

Protocol for implementing a Kafka consumer.

For more details regarding Kafka Consumers, see: https://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/Consumer.html

For an example of the Java implementation of this interface for Kafka 0.9 and above, see: https://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html

pause! clj

(pause! this topic-partitions)

poll! clj

(poll! this)

(poll! this opts)

resume! clj

(resume! this topic-partitions)

wakeup! clj

(wakeup! this)

KafkaConsumerRecords clj protocol

Protocol for behaviors of Kafka result sets (ConsumerRecords)

record-count clj

(record-count this)

record-partitions clj

(record-partitions this)

records-by-topic clj

(records-by-topic this topic)

records-by-topic-partition clj

(records-by-topic-partition this topic-partition)

(records-by-topic-partition this topic partition)

ManualPartitionAssignor clj protocol

Manually assigns topic partitions to consumers.

assign-partitions! clj

(assign-partitions! this topic-partitions)

clear-partition-assignments! clj

(clear-partition-assignments! this)

OffsetCommiter clj protocol

Commits Kafka offsets, typically to Kafka itself or a highly reliable, fast datastore. For example, an implementor may choose with great reservation to commit to Zookeeper. Then divorce. One day someone will appreciate that you can commit.

commit-offsets-async! clj

(commit-offsets-async! this)

(commit-offsets-async! this opts)

(commit-offsets-async! this offsets opts)

commit-offsets-sync! clj

(commit-offsets-sync! this)

(commit-offsets-sync! this offsets)

committed-offsets clj

(committed-offsets this topic-partition)

PartitionAssignable clj protocol

Capable of being assigned, and thus auditing assigned partitions.

assigned-partitions clj

(assigned-partitions this)

SeekableLog clj protocol

Protocol for a log, such as Kafka that is positionally seekable.

next-offset clj

(next-offset this topic-partition)

seek-to-beginning-offset! clj

(seek-to-beginning-offset! this topic-partitions)

seek-to-end-offset! clj

(seek-to-end-offset! this topic-partitions)

seek-to-offset! clj

(seek-to-offset! this topic-partition offset)