samples/kafka_service/src/produce.cpp

#include <produce.hpp>
 
#include <userver/kafka/exceptions.hpp>
 
namespace kafka_sample {
 
SendStatus Produce(const kafka::Producer& producer,
                   const RequestMessage& message) {
  try {
    producer.Send(message.topic, message.key, message.payload);
    return SendStatus::kSuccess;
  } catch (const kafka::SendException& ex) {
    return ex.IsRetryable() ? SendStatus::kErrorRetryable
                            : SendStatus::kErrorNonRetryable;
  }
}
 
}  // namespace kafka_sample