diff --git a/src/bootstrap/common.rs b/src/bootstrap/common.rs index fb299ca..5f72bfd 100644 --- a/src/bootstrap/common.rs +++ b/src/bootstrap/common.rs @@ -289,7 +289,7 @@ impl KafkaProperties { /// Check if a list of topics is present in the read topics of datastreams pub fn verify_list_of_topics( &self, - topics: Vec, + topics: &Vec, access: ReadWriteAccess, ) -> Result<(), Box> { let read_topics = self @@ -360,7 +360,7 @@ impl GroupType { } /// Get the configured topics from the environment variable TOPICS -/// The set topics can be delimited by a comma +/// Topics can be delimited by a comma pub fn get_configured_topics() -> Vec { let kafka_topic_string = match env::var("TOPICS") { Ok(s) => s, @@ -452,7 +452,7 @@ mod tests { "stream.test.test-tenant".to_string(), ]; kafka_props() - .verify_list_of_topics(topics, ReadWriteAccess::Read) + .verify_list_of_topics(&topics, ReadWriteAccess::Read) .unwrap() }