franzy.clients.consumer.types
->ConsumerOptions
(->ConsumerOptions consumer-records-fn poll-timeout-ms offset-commit-callback rebalance-listener-callback)Positional factory function for class franzy.clients.consumer.types.ConsumerOptions.
->ConsumerRecord
(->ConsumerRecord topic partition offset key value)Positional factory function for class franzy.clients.consumer.types.ConsumerRecord.
->OffsetMetadata
(->OffsetMetadata offset metadata)Positional factory function for class franzy.clients.consumer.types.OffsetMetadata.
->PartitionAssignment
(->PartitionAssignment topics user-data)Positional factory function for class franzy.clients.consumer.types.PartitionAssignment.
make-consumer-options
(make-consumer-options m)Inputs: [m] Returns: cs/ConsumerOptions
make-consumer-record
(make-consumer-record m)Inputs: [m]
make-offset-metadata
(make-offset-metadata m)Inputs: [m] Returns: cs/OffsetAndMetadata
make-partition-assignment
(make-partition-assignment m)Inputs: [m] Returns: cs/PartitionAssignment
map->ConsumerOptions
(map->ConsumerOptions m__6522__auto__)Factory function for class franzy.clients.consumer.types.ConsumerOptions, taking a map of keywords to field values.
map->ConsumerRecord
(map->ConsumerRecord m__6522__auto__)Factory function for class franzy.clients.consumer.types.ConsumerRecord, taking a map of keywords to field values.
map->OffsetMetadata
(map->OffsetMetadata m__6522__auto__)Factory function for class franzy.clients.consumer.types.OffsetMetadata, taking a map of keywords to field values.
map->PartitionAssignment
(map->PartitionAssignment m__6522__auto__)Factory function for class franzy.clients.consumer.types.PartitionAssignment, taking a map of keywords to field values.