FkafkaAdminClient constructor

FkafkaAdminClient({
  1. 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));
}