ProducerConfig.h

#pragma once
 
#include <kafka/Project.h>
 
#include <kafka/ClientConfig.h>
 
 
namespace KAFKA_API { namespace clients { namespace producer {
 
class ProducerConfig: public Config
{
public:
    ProducerConfig() = default;
    ProducerConfig(const ProducerConfig&) = default;
    explicit ProducerConfig(const PropertiesMap& kvMap): Config(kvMap) {}
 
 
    static const constexpr char* ACKS                         = "acks";
 
    static const constexpr char* QUEUE_BUFFERING_MAX_MESSAGES = "queue.buffering.max.messages";
 
    static const constexpr char* QUEUE_BUFFERING_MAX_KBYTES   = "queue.buffering.max.kbytes";
 
    static const constexpr char* LINGER_MS                    = "linger.ms";
 
    static const constexpr char* BATCH_NUM_MESSAGES           = "batch.num.messages";
 
    static const constexpr char* BATCH_SIZE                   = "batch.size";
 
    static const constexpr char* MESSAGE_MAX_BYTES            = "message.max.bytes";
 
    static const constexpr char* MESSAGE_TIMEOUT_MS           = "message.timeout.ms";
 
    static const constexpr char* REQUEST_TIMEOUT_MS           = "request.timeout.ms";
 
    static const constexpr char* PARTITIONER                  = "partitioner";
 
    static const constexpr char* MAX_IN_FLIGHT                = "max.in.flight";
 
    static const constexpr char* ENABLE_IDEMPOTENCE           = "enable.idempotence";
 
    static const constexpr char* TRANSACTIONAL_ID             = "transactional.id";
 
    static const constexpr char* TRANSACTION_TIMEOUT_MS       = "transaction.timeout.ms";
};
 
} } } // end of KAFKA_API::clients::producer