This causes segmentation fault

Signed-off-by: Hanif Bin Ariffin <[email protected]>

Author: hbina

Cargo.toml

@@ -31,6 +31,7 @@ anyhow = "1.0.38"
 thiserror = "1.0.24"
 pin-utils = "0.1.0"
 async-stream = "0.3.0"
+tabwriter = "1.2.1"
 
 [dev-dependencies]
 assert_cmd = "1"

src/modes/metadata.rs

@@ -3,11 +3,11 @@ use rdkafka::{
     config::RDKafkaLogLevel,
     consumer::{Consumer, StreamConsumer},
     metadata::Metadata,
-    ClientConfig,
+    ClientConfig, TopicPartitionList,
 };
 use tabwriter::TabWriter;
 
-pub fn get_metadata(config: AppConfig) {
+pub fn get_metadata(_config: AppConfig) {
     let stream = ClientConfig::new()
         // .set("group.id", &config.metadata_kafka.group_id)
         // .set("bootstrap.servers", &config.metadata_kafka.brokers)
@@ -19,9 +19,21 @@ pub fn get_metadata(config: AppConfig) {
         .create::<StreamConsumer>()
         .expect("Consumer creation failed");
     let metadata = Consumer::fetch_metadata(&stream, None, rdkafka::util::Timeout::Never).unwrap();
+    let position = Consumer::position(&stream).unwrap();
+    print_positions(&position);
     print_topics(&metadata);
 }
 
+fn print_positions(position: &TopicPartitionList) {
+    let inner = position
+        .elements()
+        .iter()
+        .map(|x| x.topic().to_string())
+        .collect::<Vec<_>>()
+        .join("\n");
+    println!("{}", inner);
+}
+
 fn print_topics(metadata: &Metadata) {
     // NOTE: Can be optimized by precalculating the required memory, I think.
     let mut tw = TabWriter::new(vec![]);
@@ -33,7 +45,7 @@ fn print_topics(metadata: &Metadata) {
         .map(|(idx, metadata_topic)| {
             format!(
                 "{}.\t{}\t{}\t{}",
-                idx,
+                idx + 1,
                 metadata_topic.name(),
                 metadata_topic.partitions().len(),
                 metadata_topic.error().map(|_| "true").unwrap_or("false")