68class ConsumerScope
final {
74 using Callback = std::function<
void(MessageBatchView)>;
79 ConsumerScope(ConsumerScope&&)
noexcept =
delete;
80 ConsumerScope& operator=(ConsumerScope&&)
noexcept =
delete;
128 const std::string& topic,
129 std::uint32_t partition,
130 std::optional<std::chrono::milliseconds> timeout = std::nullopt
142 GetPartitionIds(
const std::string& topic, std::optional<std::chrono::milliseconds> timeout = std::nullopt)
const;
145 friend class impl::Consumer;
147 explicit ConsumerScope(impl::Consumer& consumer)
noexcept;
149 impl::Consumer& consumer_;