1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859 |
- #ifndef MODULES_KAFKA_INCLUDE_HANDLER_HPP_
- #define MODULES_KAFKA_INCLUDE_HANDLER_HPP_
- #include <memory>
- #include <string>
- #include "cnstream_frame_va.hpp"
- #include "reflex_object.h"
- namespace cnstream {
- using CNFrameInfoPtr = std::shared_ptr<CNFrameInfo>;
- class KafkaClient;
- class KafkaHandler : virtual public ReflexObjectEx<KafkaHandler> {
- public:
- static KafkaHandler *Create(const std::string &name);
- virtual ~KafkaHandler() {}
- virtual int UpdateFrame(const CNFrameInfoPtr &data) { return 0; }
- friend class Kafka;
- protected:
- bool Produce(const std::string &content);
- bool Consume(std::string *content, int timeout_ms);
- private:
- std::string brokers_;
- std::string topic_;
- std::unique_ptr<KafkaClient> producer_ = nullptr;
- std::unique_ptr<KafkaClient> consumer_ = nullptr;
- };
- }
- #endif
|