| 26 | namespace processors { |
| 27 | |
| 28 | KafkaConnection::KafkaConnection(const KafkaConnectionKey &key) |
| 29 | : logger_(logging::LoggerFactory<KafkaConnection>::getLogger()), |
| 30 | kafka_connection_(nullptr), |
| 31 | poll_(false) { |
| 32 | initialized_ = false; |
| 33 | key_ = key; |
| 34 | } |
| 35 | |
| 36 | KafkaConnection::~KafkaConnection() { |
| 37 | remove(); |
nothing calls this directly
no outgoing calls
no test coverage detected