FkafkaConf constructor
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
);
});
}