Project

Topics

Namespaces

Public Vars

franzy.clients.consumer.schema

Schemas for Kafka Consumers and related types.

For some context, see http://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/package-frame.html

ConsumerConfig

Schema for a Kafka Consumer configuration, passed as properties to Kafka.

See http://kafka.apache.org/documentation.html#consumerconfigs

ConsumerOptions

Schema for options for a Kafka Franzy-specific consumer.

ConsumerRebalanceListenerCallback

Schema for a consumer rebalance callback.

ConsumerRebalanceListenerCallbackFn

Schema for a Kafka Consumer Rebalance Listener Callback.

See http://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html

ConsumerRebalanceListenerCallbacks

Schema for creating consumer rebalance callbacks from clojure functions.

ConsumerRecord

Schema for a Kafka Consumer Record.

See http://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/ConsumerRecord.html

OffsetAndMetadata

Schema for Kafka offset commit metadata.

See http://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/OffsetAndMetadata.html

OffsetResetStrategyEnum

Schema for a Kafka Offset Reset Strategy

See http://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/OffsetResetStrategy.html

PartitionAssignment

Schema for a Kafka partition assignment.