Method getConnection

extensions/librdkafka/KafkaConnection.cpp:74–76

}

rd_kafka_t *KafkaConnection::getConnection() const {
  return kafka_connection_;
}

bool KafkaConnection::hasTopic(const std::string &topic) const {
  return topics_.count(topic);