5#include <userver/kafka/consumer_scope.hpp>
7#include <userver/components/component_base.hpp>
8#include <userver/utils/fast_pimpl.hpp>
9#include <userver/utils/statistics/entry.hpp>
11USERVER_NAMESPACE_BEGIN
61class ConsumerComponent
final :
public components::ComponentBase {
65 static constexpr std::string_view
kName{
"kafka-consumer"};
67 ConsumerComponent(
const components::ComponentConfig& config,
const components::ComponentContext& context);
68 ~ConsumerComponent()
override;
74 static yaml_config::Schema GetStaticConfigSchema();
77 static constexpr std::size_t kImplSize = 2480;
78 static constexpr std::size_t kImplAlign = 16;
79 utils::FastPimpl<impl::Consumer, kImplSize, kImplAlign> consumer_;
83 utils::statistics::Entry statistics_holder_;