userver
C++ Async Framework
Toggle main menu visibility
Documentation
API Groups
Namespaces
Reference
Class List
Class Index
File List
Macros
All
e
i
l
r
t
u
Functions
Macros
e
i
l
r
t
u
Examples
•
All
Classes
Namespaces
Files
Functions
Variables
Typedefs
Enumerations
Enumerator
Friends
Macros
Modules
Pages
Concepts
Loading...
Searching...
No Matches
samples/kafka_service/src/consumer_handler.cpp
#include <consumer_handler.hpp>
#include <userver/kafka/consumer_component.hpp>
#include <
userver/components/component_config.hpp
>
#include <
userver/components/component_context.hpp
>
#include <consume.hpp>
namespace
kafka_sample {
ConsumerHandler::ConsumerHandler(
const
components::ComponentConfig
& config,
const
components::ComponentContext
& context)
:
components::ComponentBase
{config, context},
consumer_{context.
FindComponent
<
kafka::ConsumerComponent
>().GetConsumer()} {
consumer_.Start([
this
](
kafka::MessageBatchView
messages) {
Consume(messages);
consumer_.AsyncCommit();
});
}
}
// namespace kafka_sample
Generated on Wed Jul 23 2025 14:45:22 for userver by
Doxygen
1.9.8