franzy.clients.mocks.consumer.protocols
KafkaOffsetWriter
protocol
members
beginning-offsets!
(beginning-offsets! this topic-partition-offset-map)ending-offsets!
(ending-offsets! this topic-partition-offset-map)KafkaPartitionRebalancer
protocol
members
rebalance!
(rebalance! this topic-partitions)KafkaPartitionWriter
protocol
members
update-partitions!
(update-partitions! this topic partitions-info)KafkaPoller
protocol
members
schedule-nop-poll!
(schedule-nop-poll! this)schedule-poll!
(schedule-poll! this task)KafkaRecordWriter
protocol
members
add-record!
(add-record! this consumer-record)MockKafkaConsumerLifecycle
protocol
members
closed?
(closed? this)