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

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 clj

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

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

ConsumerOptions clj

Schema for options for a Kafka Franzy-specific consumer.

ConsumerRebalanceListenerCallback clj

Schema for a consumer rebalance callback.

ConsumerRebalanceListenerCallbackFn clj

Schema for a Kafka Consumer Rebalance Listener Callback.

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

ConsumerRebalanceListenerCallbacks clj

Schema for creating consumer rebalance callbacks from clojure functions.

ConsumerRecord clj

Schema for a Kafka Consumer Record.

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

OffsetAndMetadata clj

Schema for Kafka offset commit metadata.

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

OffsetResetStrategyEnum clj

Schema for a Kafka Offset Reset Strategy

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

PartitionAssignment clj

Schema for a Kafka partition assignment.