70class ConsumerScope
final {
76 using Callback = std::function<
void(MessageBatchView)>;
81 ConsumerScope(ConsumerScope&&)
noexcept =
delete;
82 ConsumerScope& operator=(ConsumerScope&&)
noexcept =
delete;
134 std::uint32_t partition,
135 std::optional<std::chrono::milliseconds> timeout = std::nullopt
178 std::uint32_t partition_id,
179 std::uint64_t offset,
180 std::chrono::milliseconds timeout
211 friend class impl::Consumer;
213 explicit ConsumerScope(impl::Consumer& consumer)
noexcept;
215 impl::Consumer& consumer_;