ConsumerConfig.h

#pragma once
 
#include <kafka/Project.h>
 
#include <kafka/ClientConfig.h>
 
 
namespace KAFKA_API { namespace clients { namespace consumer {
 
class ConsumerConfig: public Config
{
public:
    ConsumerConfig() = default;
    ConsumerConfig(const ConsumerConfig&) = default;
    explicit ConsumerConfig(const PropertiesMap& kvMap): Config(kvMap) {}
 
 
    static const constexpr char* GROUP_ID                = "group.id";
 
    static const constexpr char* ENABLE_AUTO_COMMIT      = "enable.auto.commit";
 
    static const constexpr char* AUTO_OFFSET_RESET       = "auto.offset.reset";
 
    static const constexpr char* ENABLE_PARTITION_EOF    = "enable.partition.eof";
 
    static const constexpr char* MAX_POLL_RECORDS        = "max.poll.records";
 
    static const constexpr char* QUEUED_MIN_MESSAGES     = "queued.min.messages";
 
    static const constexpr char* SESSION_TIMEOUT_MS      = "session.timeout.ms";
 
    static const constexpr char* ISOLATION_LEVEL         = "isolation.level";
 
    /*
     * The name of one or more partition assignment strategies.
     * The elected group leader will use a strategy supported by all members of the group to assign partitions to group members.
     * Available options: range, roundrobin, cooperative-sticky
     * Default value: range,roundrobin
     */
    static const constexpr char* PARTITION_ASSIGNMENT_STRATEGY = "partition.assignment.strategy";
};
 
} } } // end of KAFKA_API::clients::consumer