FkafkaConf constructor

FkafkaConf(
  1. Map<String, String> conf
)

Implementation

FkafkaConf(Map<String, String> conf) {
  _conf = UnmodifiableMapView(conf);
  _confPtr = _bridges.rd_kafka_conf_new();

  // set kafka native conf
  _conf.forEach((key, value) {
    _bridges.rd_kafka_conf_set(
        _confPtr,
        key.toNativeUtf8(),
        value.toNativeUtf8(),
        nullptr,
        nullptr
    );
  });
}