FkafkaTopic.metadata constructor
FkafkaTopic.metadata(
- 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()
);