ConsumerCommon.h

#pragma once
 
#include <kafka/Project.h>
 
#include <kafka/Error.h>
#include <kafka/RdKafkaHelper.h>
#include <kafka/Types.h>
 
#include <librdkafka/rdkafka.h>
 
#include <functional>
 
 
namespace KAFKA_API { namespace clients { namespace consumer {
 
    enum class RebalanceEventType { PartitionsAssigned, PartitionsRevoked };
 
    using RebalanceCallback = std::function<void(RebalanceEventType eventType, const TopicPartitions& topicPartitions)>;
 
#if COMPILER_SUPPORTS_CPP_17
    const inline RebalanceCallback NullRebalanceCallback = RebalanceCallback{};
#else
    const static RebalanceCallback NullRebalanceCallback = RebalanceCallback{};
#endif
 
    using OffsetCommitCallback = std::function<void(const TopicPartitionOffsets& topicPartitionOffsets, const Error& error)>;
 
#if COMPILER_SUPPORTS_CPP_17
    const inline OffsetCommitCallback NullOffsetCommitCallback = OffsetCommitCallback{};
#else
    const static OffsetCommitCallback NullOffsetCommitCallback = OffsetCommitCallback{};
#endif
 
    class ConsumerGroupMetadata
    {
    public:
        explicit ConsumerGroupMetadata(rd_kafka_consumer_group_metadata_t* p): _rkConsumerGroupMetadata(p) {}
 
        const rd_kafka_consumer_group_metadata_t*  rawHandle() const { return _rkConsumerGroupMetadata.get(); }
 
    private:
        rd_kafka_consumer_group_metadata_unique_ptr _rkConsumerGroupMetadata;
    };
 
} } } // end of KAFKA_API::clients::consumer