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