newTopic method

FkafkaTopic newTopic(
  1. String topic
)

create topic

TODO customize topic conf

Implementation

FkafkaTopic newTopic(String topic) {
  assert(topic.isNotEmpty);
  var topicPtr = _bridges.rd_kafka_topic_new.call(
      _pc._kafkaPtr,
      topic.toNativeUtf8(),
      nullptr
  );

  var result =  FkafkaTopic.ptr(topicPtr);
  _bridges.rd_kafka_topic_destroy(topicPtr);
  return result;
}