FkafkaAdminClient constructor
FkafkaAdminClient({
- required FkafkaConf conf,
Implementation
FkafkaAdminClient({
required FkafkaConf conf
}) {
_pc = FkafkaProducerClient(conf: conf);
// add consumer conf
_ccBaseConf = Map<String, String>.from(conf.conf)
..addAll({
CLIENT_ID_CONFIG: 'dart_fkafka_admin',
ENABLE_AUTO_COMMIT_CONFIG: 'false',
AUTO_OFFSET_RESET_CONFIG: 'earliest',
ISOLATION_LEVEL_CONFIG: 'read_committed',
});
_cc = FkafkaConsumerClient(conf: FkafkaConf(_ccBaseConf));
}