FkafkaTopic.metadata constructor

FkafkaTopic.metadata(
  1. rd_kafka_metadata_topic topicMetadata
)

Implementation

factory FkafkaTopic.metadata(rd_kafka_metadata_topic topicMetadata) => FkafkaTopic(
    name: topicMetadata.topic.toDartString(),
    partitionCount: topicMetadata.partition_cnt,
    partitions: topicMetadata.partitionList.map((_) => FkafkaPartition(id: _.id)).toList()
);